我有一群卡夫卡经纪人。我正在尝试获取主题级别的指标,对于驻留在代码所指向的特定代理上的主题,我已经成功地做到了这一点。Zookeeper返回所有代理上所有主题的列表。当我尝试获取每个主题的指标时,这会导致失败。
我使用此函数从zookeeper获取主题列表:
ZooKeeper zk = new ZooKeeper("kafka.ip:port", 1000, null);
return zk.getChildren("/brokers/topics", false);
为了获得主题指标,我使用了JMX。JMX连接器仅指向单个代理。当我用来获取指标的代码遇到一个不存在于该代理上的主题时,它会失败,因为该主题在代理的眼中并不存在。
这就引出了我的问题:有没有办法让一个话题继续存在的经纪人?有没有更好的方法来做这件事?
谢谢!
https://stackoverflow.com/questions/56242555
复制相似问题