如何手动将代理 ID 添加到 zookeeper cli

how to add broker id manually to zookper cli

我们有 kafka 包含 3 台代理机器的集群 和 3 zookeeper 台服务器

所有服务器都安装了redhat 7.2版本

但是当我们运行下面的cli(为了知道所有代理id都存在于zookeeper中,我们得到:

zookeeper-shell.sh zoo_server:2181 <<< "ls /brokers/ids"

WATCHER::

WatchedEvent state:SyncConnected type:None path:null
[3, 2]

而不是:

[3, 2 , 1]

我们通过搜索 server.log

中的错误检查了第一个经纪人 ( kafka01 )

而且我们在日志中没有看到任何相关错误!

从 kafka broker 到 zookeeper 机器的端口 2181 正在工作

我们也重新启动 kafka01 ,但这无助于在 zookeeper cli 中获取 broker id

我们也尝试重新启动所有 zookeeper 服务器(有 3 个),然后再次重新启动 kafka01,但仍然没有结果

对这种行为有什么建议吗?

我们可以将缺少的代理添加到 zookeeper cli 吗? , 如果是那么怎么办?

注意 - 我看到另一个线程 - https://community.cloudera.com/t5/Support-Questions/Specified-config-does-not-exist-in-ZooKeeper/td-p/1875

但没有关于如何将 id 添加到 zookeeper 的信息

解决方法很简单

我们所做的是

  1. 重启所有动物园管理员服务器
  2. 重启所有kafka服务器

现在我们可以看到所有经纪人 ID