请问有相关的Java API可以查到kafka哪台服务器是controller吗?
在详细点,控制什么的呢?
就是在Kafka集群中的一个broker会被作为controller负责管理分区和副本的状态以及执行类似于重分配分区之类的管理任务。我想知道我的集群哪一个broker是作为这个controller的?可有相关的Java Api可以查到这个?
命令的话,你可以在命令大全 https://www.orchome.com/454 找。API的话是有的,不过你要自己找,太久了我忘记名字了,你可以在KafkaOffsetMonitor源码找下。
不过我们都通过monitor进行监控,不需要单独调用API进行特别管理的。
找不到想要的答案?提一个您自己的问题。
0 声望
这家伙太懒,什么都没留下
在详细点,控制什么的呢?
就是在Kafka集群中的一个broker会被作为controller负责管理分区和副本的状态以及执行类似于重分配分区之类的管理任务。我想知道我的集群哪一个broker是作为这个controller的?可有相关的Java Api可以查到这个?
命令的话,你可以在命令大全 https://www.orchome.com/454 找。
API的话是有的,不过你要自己找,太久了我忘记名字了,你可以在KafkaOffsetMonitor源码找下。
不过我们都通过monitor进行监控,不需要单独调用API进行特别管理的。
你的答案