一个集群中有多少个Kafka控制器,控制器的目的是什么?

金泰宇

Kafka集群中的Kafka控制器负责管理分区领导者和复制。

如果Kafka集群中有100个经纪人,那么控制者仅仅是一个Kafka经纪人吗?那么在100个经纪人中,控制者是领导者吗?

您怎么知道控制者是哪个经纪人?

Kafka Controller的管理对Kafka系统管理是否至关重要?

Giorgos Myrianthous

在Kafka群集中,单个代理充当活动控制器,负责分区和副本的状态管理。因此,在您的情况下,如果您有一个包含100个代理的集群,则其中一个将充当控制器。

可以在此处找到有关集群控制器职责的更多详细信息

为了找到哪个代理是群集的控制器,您首先需要通过ZK CLI连接到Zookeeper:

./bin/zkCli.sh -server localhost:2181 

然后get是控制器

[zk: localhost:2181(CONNECTED) 0] get /controller

输出应如下所示:

{"version":1,"brokerid":100,"timestamp":"1506423376977"}
cZxid = 0x191
ctime = Tue Sep 26 12:56:16 CEST 2017
mZxid = 0x191
mtime = Tue Sep 26 12:56:16 CEST 2017
pZxid = 0x191
cversion = 0
dataVersion = 0
aclVersion = 0
ephemeralOwner = 0x15ebdd241840002
dataLength = 56
numChildren = 0

Zookeeper是Kafka群集状态的存储。它在开始时或当前控制器崩溃时用于控制器选择。当主题的分区领导者失败/崩溃时,控制器还负责告诉其他副本成为分区领导者。

本文收集自互联网,转载请注明来源。

如有侵权,请联系 [email protected] 删除。

编辑于
0

我来说两句

0 条评论
登录 后参与评论

相关文章

一个AngularJS文件中有多少个控制器(服务,工厂,指令)

控制器中有多少个参数?

在线程安全的弹簧控制器中查找队列中有多少个请求

我可以让一个变量在控制器中有一个 AKA 吗?

您好,我正在使用“收藏夹视图”单元格,我想记录一下其中有多少个被单击为“ true”并返回到下一个视图控制器

角度-从另一个控制器调用特定于控制器的功能的最佳实践是什么?

一个控制器中有2个集合视图单元

关于MVC控制器与单独的Web API的体系结构,有多少个项目?

创建一个控制器

一个控制器中有多个模型,可在Codeigniter中进行编码实践

一个控制器中有多个存储库

使用多个入口控制器-是否可以有一个“默认”控制器?

将具有不同操作的控制器路由到一个控制器

一个控制器,内部有动作

一个GSP中有多个<g:select>,控制器内部的HQL中有多个参数

从另一个控制器触发一个控制器的“动作”

如何将数据从一个视图控制器传递到另一个视图控制器,并且在视图控制器之间有一个显示视图控制器

为什么 .isNotNull(); 即使我有一个控制器类,断言也会失败?

如何使两个控制器共享一个控制器动作?

在同一个 AKS 集群中安装多个 nginx 入口控制器实例

我将在此应用设置中使用多少个视图控制器?

是什么使这两个控制器相关?

Angular JS-一个控制器中有多个ng-grid:主/详细

控制器中有多个method = RequestMethod.POST,如何调用它们中的每一个?

哪个使用更少的内存?一个带有 5 个按钮的视图控制器,或者一个带有 5 个项目的 tableview 的视图控制器?

如何从另一个控制器修改模型(没有控制器)的表?

Swift:关闭所有视图控制器,然后呈现一个视图控制器

如何从当前视图控制器弹出上一个视图控制器?

另一个控制器中的呼叫控制器-CodeIgniter