2017-10-26 1 views
0

2つのパーティションと1つのレプリカでそれぞれカフカトピックXとYが作成されました。kafka接続がポーリング中にコンシューマグループスレッドから拒否されました

上記のkafkaコンテナと9092とzookeeperで動作する2つのJavaプロセス(mavenモジュール)がkafka-clientの2つあります。

JVMは両方ともkafkaに正常に接続しており、両方ともトピックが存在するかどうかを確認できます。しかし、一方のJVMはコンシューマ・グループを正常に登録できますが、他方のJVMはコンシューマ・グループを登録できません。

接続が拒否されたkafkaへのポーリング中にコンシューマスレッド(シングルスレッドに設定)が失敗します。 2つのユニークなトピックと2つの固有の消費者グループがあります。

異なるJVMの2つのコンシューマ・グループを必要とする場合、2つのブローカ、つまり2つのカフカ・コンテナが必要ですか?

! java.net.ConnectException: Connection refused 
! at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method) ~[na:1.8.0_144] 
! at sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717) ~[na:1.8.0_144] 
! at org.apache.kafka.common.network.PlaintextTransportLayer.finishConnect(PlaintextTransportLayer.java:51) ~[app.jar:1.5.0.0-SNAPSHOT] 
! at org.apache.kafka.common.network.KafkaChannel.finishConnect(KafkaChannel.java:73) ~[app.jar:1.5.0.0-SNAPSHOT] 
! at org.apache.kafka.common.network.Selector.pollSelectionKeys(Selector.java:323) [app.jar:1.5.0.0-SNAPSHOT] 
! at org.apache.kafka.common.network.Selector.poll(Selector.java:291) [app.jar:1.5.0.0-SNAPSHOT] 
! at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:260) [app.jar:1.5.0.0-SNAPSHOT] 
! at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:232) [app.jar:1.5.0.0-SNAPSHOT] 
! at org.apache.kafka.clients.consumer.internals.ConsumerNetworkClient.poll(ConsumerNetworkClient.java:180) [app.jar:1.5.0.0-SNAPSHOT] 
! at org.apache.kafka.clients.consumer.internals.AbstractCoordinator.ensureCoordinatorReady(AbstractCoordinator.java:193) [app.jar:1.5.0.0-SNAPSHOT] 
! at org.apache.kafka.clients.consumer.internals.ConsumerCoordinator.poll(ConsumerCoordinator.java:248) [app.jar:1.5.0.0-SNAPSHOT] 
! at org.apache.kafka.clients.consumer.KafkaConsumer.pollOnce(KafkaConsumer.java:1013) [app.jar:1.5.0.0-SNAPSHOT] 
! at org.apache.kafka.clients.consumer.KafkaConsumer.poll(KafkaConsumer.java:979) [app.jar:1.5.0.0-SNAPSHOT] 
! at 

答えて

0

気にしないで、私の悪いが...それがポートエラーだった、1 JVMは、それが飼育係に接続するが、カフカ

で失敗した...代わりに9092の間違ったポートを指すカフカのためのブートストラップ・サーバーを持っていました
関連する問題