②③④⑤⑥⑪
/my_topic/partion-2/replica0/my_topic/partion-1/replica1
⑩
Consumer
zookeeper
/my_topic/partion-0/replica0/my_topic/partion-2/replica1
①②
③
KafkaController(Standby)
broker 3
Producer
① ProducerRequest 消息发送② TopicMetadataRequest获取 Topic 元数据信息③ FetchRequest消费者获取感兴趣的 Topic 的某个分区的消息的请求④ OffsetRequest获取点前 Topic 所在分区在不同时间段的偏移量详情⑤ OffsetCommitRequest消费者提交 Topic 被消费的分区信息到 Broker，Broker 持久化偏移量信息⑥ OffsetFetchRequest发送消费 Topic 被消费的详细信息到集群⑦ LeaderAndIsrRequestLeader 状态的分区 broker 发送变化信息到对应 Follower 的 broker⑧ StopReplicaRequestLeader Broker 通知相关 Flower broker 分区下线信息⑨ UpdateMetadataRequest通知元数据信息变化⑩ BrokerControlledShutdownRequestbroker 正常下线时通知 Leader⑪ ConsumerMetadataRequest保存特定 Consumer Group 消费详情的分区信息
KafkaController(Leader)
broker 1
/my_topic/partion-1/replica0/my_topic/partion-0/replica1
①②③④⑤⑥⑪
⑦⑧⑨
broker 2
