如下图所示：
Broker共处理10种request，分别如下：
①ProducerRequest：生成者发送消息至KAFKA集群/或者消费者提交偏移量至KAFKA的log的请求
②TopicMetadataRequest： 生产者发送/消费者发送获取topic的元数据信息的请求
③FetchRequest：消费者发送/ReplicaFetcherThread发送获取message的请求
④OffsetRequest： 消费者发送获取某个topic的偏移量的请求
⑤OffsetCommitRequest：消费者发送提交偏移量至KAFKA（内部又根据配置提交至ZK或者log)的请求
⑥OffsetFetchRequest： 消费者发送获取自己提交到KAFKA上的偏移量(如果是ZK上，则消费者自己获取)的请求
⑦LeaderAndIsrRequest：当某个topic的partition的leader和isr发生改变时，Controller发送通知给相应的broker(比如说leader挂了)的请求
⑧StopReplicaRequest： 当broker停止时或者删除某个topic的分区的replica时，Controller发送通知相应的broker停止拷贝副本的请求
⑨UpdateMetadataRequest：当topic的元数据信息发生变化时，Controller发送通知给相应的Broker的请求
⑩BrokerControlledShutdownRequest：当集群内某个broker关机的时候，Broker(作为leader的controller)接收到的对应的broker准备关机的请求
原创文章，作者：ItWorker，如若转载，请注明出处：https://blog.ytso.com/11823.html