如何手动将代理 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 的信息
解决方法很简单
我们所做的是
- 重启所有动物园管理员服务器
- 重启所有kafka服务器
现在我们可以看到所有经纪人 ID
我们有 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 的信息
解决方法很简单
我们所做的是
- 重启所有动物园管理员服务器
- 重启所有kafka服务器
现在我们可以看到所有经纪人 ID