找机会的码仔

# kafka

java(33) maven(1) mysql(1) redis(1) 微服务(2) 数据库(8) 未归档(2) 算法(15)

/ 注册

全部文章 / # kafka （共2篇）

kafka(二)：生产与消费

发送消息的幂等性 Broker有判断producer生产消息幂等性的功能：具体设置： enable.idempotence=true/false 原理 PID(Producer ID) sequence number 生产者都要有一个唯一的编号，就是PID。每一条消息都要有一个...

2022-05-25

0 0

kafka(三)：选举机制

Leader选举利用zk选举 zk的三个特性： watch机制节点不允许重复写入使用临时节点在开始时所有的副本都去zk创建一个临时节点，先创建成功的副本就成为leader，后面的副本都watch这个临时节点，leader挂掉后就会触发watch事件，所有的副本开始重新选...

2022-05-25

0 0