kafka源码解析之五Broker处理的request的来源
2016-03-24 15:29
701 查看
如下图所示:
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准备关机的请求
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准备关机的请求
相关文章推荐
- 60. Permutation Sequence | Java最短代码实现
- UI控件
- 读书笔记 Think in Java 4th 第十一章 持有对象 List、Set、Queue和Map
- 设置UITextField的左边距
- Gradle初探(二):build.gradle常用配置(java和web项目)
- SyntaxError: JSON.parse: unexpected character at line 1 column 1 of the JSON data情况在easyui 的datagrid
- UISwitch
- android 蓝牙 通信 bluetooth
- Arduino PID Autotune Library
- 使用Jmeter中的Java Request进行性能测试
- Java,break与continue区别(二)
- iOS开发——状态栏(UIStatusBar)的相关设置方法总结
- 深入理解IEnumerable和IQueryable两接口的区别
- vs2013无法创建html,不能发布:The web publishing extension is not installed which is required to publish
- hbuilder git 新建共享项目
- 基于UItableViewHeaderFooterView用故事板添加视图的方法
- Named Return Value Optimization
- WPF:UIElement以及FrameworkElement中常见事件的运行顺序
- ubuntu打软件报错
- BZOJ 3638 k-Maximum Subsequence Sum