Kafka集群中的Kafka控制器负责管理分区领导者和复制。
如果Kafka集群中有100个经纪人,那么控制者仅仅是一个Kafka经纪人吗?那么在100个经纪人中,控制者是领导者吗?
您怎么知道控制者是哪个经纪人?
Kafka Controller的管理对Kafka系统管理是否至关重要?
在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] 删除。
我来说两句