kafkaクライアントプロデューサがJavaでメッセージを送信する前に実行されていることを確認します

Question

私はkafkaクライアントv 0.8.0 jarファイルを使用してカフカメッセージをプロデューサとして送信しています。しかし、それを送る前に私はカフカが起きているかどうかチェックしたい。これはどうすればいいですか？

Answer 1

ブローカーがZookeeperに存在するかどうかを確認できます。

ブローカーのIDは、他のブローカーや消費者が 障害を検出することができた、 エフェメラルノードとして飼育係（/ブローカー/ IDS/[brokerId]）に登録されている。（今の健康の定義はかなりナイーブです。、 がzk/brokers/ids/[brokerId]に登録されている場合は、ブローカーは正常ですが、それ以外の場合は です。

詐欺師のセッションが アクティブである限り、飼い猫の一時的なノードは存在します。

ブローカーはあなただけを直接確認したい場合は/ブローカー/ IDS

see stack overflow question

の下にあるすべてのアクティブなブローカー IDを返し ZkUtils.getSortedBrokerList（zkClient）、を経由してアップしている場合は、チェックできますブローカーが死亡したときに acksプロパティを1に設定するか、またはすべて（-1）または/およびmax.in.flight.requests.per.connectionプロパティを1に設定します。