Kafka是通过哪些机制提高吞吐量


Kafka是通过哪些机制提高吞吐量 磁盘、内存、网络IO 磁盘顺序读写 充分利用磁盘预读,避免随机读写造成磁盘寻道造成的开销 零拷贝 Kafka是消息中转站,无需对消息进行加工处理 使用零拷贝技术,磁盘加载到直接内存,不进入JVM中,避免了CPU对数据进行内存拷贝:磁盘->内核态内存->Socket

使用Kafka时如何确保消息不丢失


使用Kafka时如何确保消息不丢失 可靠性的提高一定程度会降低吞吐量 Topic配置 配置多个消息副本 消息生产者侧 使用同步发送 根据业务需要,设置ack为1或all(设置1时leader写入完成则确认,设置all时至少指定个数的leader、follower写入完成时确认),确保收到Kafka响
弹