轮询时从使用者组线程拒绝了kafka连接

Question

创建了一个kafka主题X和Y，每个主题有2个分区和1个副本。它运行在连接到第二个容器“Zookeeper”的一个名为“Kafka”的docker容器上

有两个Java进程（maven模块）具有完全相同版本的kafka-client连接到上面运行在9092和Zookeeper上的kafka容器。

使用者线程（配置为单线程）在轮询kafka时失败，连接被拒绝。有两个独特的话题，有两个独特的消费群体。

如果需要来自不同JVM的两个消费者组，我需要两个代理（即两个kafka容器）吗？

! 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 

Answer 1

不要紧，我的坏处..这是端口错误，一个JVM的bootstrap-server for kafka指向错误的端口，而不是9092。它与zookeeper连接但与kafka连接失败