生产者
Kafka集群
Topic CPartition 1(follower)
PULL
Zookeeper集群
Broker2
同步ISR信息
.......
PUSH
入库
消息消费
Topic APartition1(follower)
Topic CPartition 1(leader)
Topic BPartition 1(leader)
Controller
同步消息
Topic APartition 2(follower)
Broker1
Topic APartition 1(leader)
Topic BPartition 1(follower)
Broker3
Topic APartition2(leader)
消息处理中心
消息处理
委办局
消息监听