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]
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 を追加する方法についての情報はありません