zookeeper在kafka中的应用
所属分类 zookeeper
浏览量 1026
存储 consumer 和 broker 的信息
broker
broker 列表 broker 向 zk 发送心跳 上报状态
控制器选举
控制器负责管理整个集群所有分区和副本的状态,例如某个分区的 leader 挂了,控制器会选举新的 leader
ISR 信息
ISR(in-sync replica) ISR中的副本才能被选为 leader
topic信息
topic 列表
topic 的 partition信息
consumer
offset
老版本 consumer 的消费偏移量存储在zk 中
新版本 offset 更新到 kafka自带的topic __consumer_offsets 下面
consumer 自动注册 临时节点
分区消费信息
每个 partition 只能被消费组中的一个 consumer 消费
partition 与 consumer 的对应关系
kafka消费者offset记录位置和方式
上一篇
下一篇
java面试题
NoSQL 简介
zookeeper为何不适合做服务发现
zookeeper如何保证数据一致性
JVM GC 过程简介
micrometer使用