でのアクティブコントローラを識別

コントローラとは

コントローラはKafkaブローカのうちの1つです.そして、通常、通常のブローカーとしてふるまい、パーティション状態とレプリカを管理する制御能力を持ちます、そして、パーティションの再割り当て.

現在のアクティブコントローラを取得するには？

ZooKeeperは、クラスタ設定の開始またはコントローラノードがクラッシュしたときにコントローラノードを選択するKafkaクラスタのストレージです.コントローラを得るためのコマンドです

シェルコマンドをホストにインストールしました

zookeeper-shell 192.168.1.1:22181 get /controller

私たちがDockerコンテナを扱うとき、以下のコマンドを対話モードで実行することができます

# Connect to Zookeeper
docker run --net=host --rm confluentinc/cp-kafka:4.0.0 zookeeper-shell 192.168.1.1:22181

# Get the Controller
docker run --net=host --rm confluentinc/cp-kafka:4.0.0 zookeeper-shell 192.168.1.1:22181 get /controller

Note: 192.168.1.1 is the zookeeper IP