kafka_communication_protocol

②③④⑤⑥⑪

/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