阅读量:3
Kafka 消息不丢失的原因有以下几点：
持久化存储：Kafka 使用持久化存储将消息写入磁盘，确保消息在发送后不会丢失。
冗余备份：Kafka 使用副本机制，将每个分区的消息复制到多个 broker 中，并保证至少有一个副本可用。当一个 broker 发生故障时，可以从其他副本中获取数据，避免消息丢失。
批量发送：Kafka 允许将多条消息批量发送到服务器，减少了网络传输开销和磁盘写入次数，提高了消息的可靠性。
顺序写入：Kafka 采用顺序写入的方式将消息写入磁盘，避免了磁盘随机写入的性能问题。
消息复制确认机制：Kafka 使用复制确认机制来确保消息被成功写入多个副本。只有当所有副本都成功写入后，生产者才会收到确认。
客户端批量拉取：Kafka 客户端可以批量拉取多个消息，减少了网络传输开销，提高了消息的可靠性。
快速复制：Kafka 采用零拷贝技术进行消息的复制，减少了数据在内存和磁盘之间的复制次数，提高了复制效率和消息的可靠性。
总之，Kafka 通过持久化存储、冗余备份、批量发送、顺序写入、复制确认机制、客户端批量拉取和快速复制等多种机制来确保消息的可靠性，从而尽可能避免消息丢失。
