kafka
2021-01-13 13:57:52 2 举报Kafka底层原理
作者其他创作
大纲/内容
从所有Broker中选举出Controller维护所有Broker的ISR集合
Topic APartition 0Follow
broker-0
PUSH
Kafka底层逻辑细节
consumer 1
PULL
SYNC
kafka cluster
zookeeper cluster
选择一个Broker作为组协调器开启消费者rebalance
consumer 2
1. producer先从zookeeper的\"/brokers/.../state\
Topic BPartition 0Follow
consumer
Topic BPartition 0Leader
Topic CPartition 0Leader
Producer 2
注册
Controller
提交consumer_offsetskey=consumerGroupID+tapic+分区号value = offset
内部Topic 50个分区_consumer_offsets
Producer 1
Producer
Topic APartition 1Leader
Topic CPartition 0Follow
broker-1
consumer group 0
broker-2
consumer group 1
Producer 0
Topic APartition 0Leader
0 条评论
下一页
