0

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

所有服务器都安装在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]

我们kafka01通过在server.log

而且我们在日志中看不到任何相关的错误！

从 kafka 代理到 Zookeeper 机器的端口 2181 正在工作

我们也重新启动kafka01，但这无助于在 zookeeper cli 中获取代理 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 的信息

4

1 回答 1

1

解决方案很简单

我们所做的是

  1. 重新启动所有 zookeepers 服务器
  2. 重启所有kafka服务器

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

于 2019-09-12T09:20:57.057 回答