0

kafka3 つのブローカー マシンと 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]

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

しかし、Zookeeper に ID を追加する方法についての情報はありません

4

1 に答える 1