1.生产者：往Broker写入消息时，发生网络错误，消息不可达。
2.Broker：分区leader收到消息，同步分区复制到新消息之前，分区leader崩溃。
3.消费者：读取到一批消息，消费者提交了偏移量却未能处理读到的消息（如数据需要的算力很大，处理时间会很长），这是消费者丢消息的主要原因。
Kafka消息丢失原因
猜你喜欢
转载自blog.csdn.net/Wengzhengcun/article/details/83930851
今日推荐
周排行