org.apache.kafka.clients.NetworkClientブートストラップブローカブートストラップサーバ - IP：9092 disconnected

Question

私のローカルシステム上でapache kafkaを実行していて、絶対にうまく動作しています。しかし、煙のテスト中、私のアプリケーションはカフカクラスターに接続できません。それは際限なく次のエラーを投げ続ける：

propsMap.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, "<host1>:9092,<host2>:9092); 
propsMap.put("zookeeper.connect", "<host1>:2181,<host2>:2181"); 
propsMap.put(ConsumerConfig.ENABLE_AUTO_COMMIT_CONFIG, false); 
propsMap.put(ConsumerConfig.AUTO_COMMIT_INTERVAL_MS_CONFIG, "100"); 
propsMap.put(ConsumerConfig.SESSION_TIMEOUT_MS_CONFIG, "15000"); 
propsMap.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class); 
propsMap.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class); 
propsMap.put(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG, "earliest"); 
propsMap.put(ConsumerConfig.GROUP_ID_CONFIG, "test"); 

を、それは私の展開サーバーができないため、これに煙サーバ上のネットワークの問題だろう：私は接続するには、以下の消費者の設定を使用しています

[2016-11-22T23:04:35,017][WARN ][org.apache.kafka.clients.NetworkClient] Bootstrap broker <host1>:9092 disconnected 
[2016-11-22T23:04:35,474][WARN ][org.apache.kafka.clients.NetworkClient] Bootstrap broker <host2>:9092 disconnected 
[2016-11-22T23:04:35,951][WARN ][org.apache.kafka.clients.NetworkClient] Bootstrap broker <host1>:9092 disconnected 
[2016-11-22T23:04:36,430][WARN ][org.apache.kafka.clients.NetworkClient] Bootstrap broker <host2>:9092 disconnected 

カフカサーバーに接続しますか？私のローカルと他の2つのテスト環境でうまく動作しているからです。

カフカ版と関係がありますか？

この場合、接続するためにSSLなどの他の設定を追加する必要がありますか？

私はカフカを初めて利用しています。誰かが私を正しい方向に向けることができれば、本当に役に立ちます！

Answer 1

Kafka 0.9.x.x以降のクライアント（spring-kafkaを使用している場合）を使用している場合は、zookeeper.connectプロパティは必要ありませんが、問題はありません。

ブローカーがダウンしている場合、私はあなたがそこに便利なものがありますかどうかを確認するために、サーバのログを見てお勧め何か

WARN o.apache.kafka.clients.NetworkClient - Connection to node -1 could not be established. Broker may not be available. 

のように、あなたが取得する必要があります。 SSL/SASL/Kerberosなどを接続する必要があるかどうかを知るためには、管理者と話をする必要があります。