创建了一个kafka主题x和y,每个主题有2个分区和1个副本。它运行在一个称为“Kafka”的docker容器上,链接到第二个容器“zookeeper”
有两个java进程(maven模块)与运行在9092和zookeeper上的kafka容器连接到完全相同版本的kafka客户端。
两个jvm都成功地连接到kafka,并且都能够检查主题是否存在。但是,一个jvm也能够成功注册使用者组,而第二个jvm无法注册使用者组。
使用者线程(配置为单线程)在轮询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
1条答案
按热度按时间hjqgdpho1#
没关系,我的错。。这是端口错误,一个jvm让kafka的引导服务器指向错误的端口,而不是9092。。它与zookeeper有联系,但与Kafka没有联系