(一)
Kafka 提供的用于查询消费者组的脚本是 kafka-consumer-groupssh(bat)
(二)
Kafka提供了分区重分配脚本工具 kafka-reassign-partitions.sh(bat)
(三)
(四)
客户端API管理topic
Kafka自己实现了一套二进制协议(binary protocol)用于各种功能的实现,比如发送消息获取消息、提交位移以及创建 topic等。这套协议的具体使用流程如下。
客户端创建对应协议的请求。
客户端发送请求给对应的 broker。
broker处理请求,并发送response给客户端。
(五)
对于 Kafka 企业级用户而言,一个常见的痛点就是跨机房或跨数据中心 (data center,DC)的数据传输。大型企业通常在多个数据中心部署 Kafka 集群。这里的数据中心可能是企业拥有的自建机房,也可能是公有云厂商的不同机房。在多个机房部署 Kafka集群的优势如下。
实现灾备。
较近的地理位置可缩短延时以及用户响应时间。
实现负载均衡,即每个数据中心上的集群可能只保存部分数据集合。
区别隔离不同优先级的数据处理。
(六)
如果您发现该资源为电子书等存在侵权的资源或对该资源描述不正确等,可点击“私信”按钮向作者进行反馈;如作者无回复可进行平台仲裁,我们会在第一时间进行处理!
添加我为好友,拉您入交流群!
请使用微信扫一扫!