Kafka无消息丢失实现

一、Kafka 无消息丢失核心概念 Kafka 只对“已提交”的消息做有限度的持久化保证。 二、生产者程序丢失数据 目前Kafka Producer 是异步发送消息，也就是说如果你调用的是 producer.send(msg)这个API，那么它通常会立即返回，但此时你不能认为已经发送成功了。 如果出现消息丢失，我们是无法知晓的， 这种发送方式不靠谱，不过还有一些公司在用这种API发送消息。 这种发

>>阅读原文<<