kafka核心技术与实战

已提交

有限度

kafka只对\"已提交\"的消息做有限度的持久化

网络抖动

消息不合格

发送后立即返回

要使用带有回调通知的发送API

生产者丢消息

先更新位移，才消费消息

多线程异步消费，有线程消费失败，位移自动更新

消费者丢消息

使用带有回调通知的send方法

配置retries重试

生产者

unclean.leader.election.enable = false，不允许落后leader太多的Broker成为分区的leader

replication.factor >=3 多保存几份消息

min.insync.replicas >1 消息至少要写入多少个副本才能算是\"已提交\"

Broker端

确保消息消费完再提交

enable.auto.commit = false，最好手动提交位移

消费者

最佳实践

如何不丢消息

消费者组

kafka