微服务架构之–消息队列Kafka图解最全知识点

每个 broker 都会在 zookeeper 的临时节点 "/controller" 注册 watcher，当 controller 宕机时 "/controller" 会消失，触发broker的watch，每个 broker 都尝试创建新的 controller path，只有一个竞选成功并当选为 controller。

使用Kafka如何保证幂等性

不丢消息

• 首先kafka保证了对已提交消息的at least保证
• Sender有重试机制
• producer业务方在使用producer发送消息时，注册回调函数。在onError方法中重发消息
• consumer 拉取到消息后，处理完毕再commit，保证commit的消息一定被处理完毕

不重复

consumer拉取到消息先保存，commit成功后删除缓存数据

Kafka高性能

• partition提升了并发
• zero-copy
• 顺序写入
• 消息聚集batch
• 页缓存

业务方对 Kafka producer的优化

• 增大producer数量
• ack配置
• batch

（编辑：威海站长网）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!