kafka核心技术与实战
2023-02-01 00:24:15 0 举报AI智能生成
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
0 条评论
回复 删除
下一页
