Docker环境下Kafka消费者无法接收消息的问题求助
Docker环境下Kafka消费者无法接收消息的问题求助
大家好,我现在遇到个棘手的问题——用Docker Compose搭了一套最基础的Kafka生产者/消费者环境,同时部署了ZooKeeper和Kafka服务。看起来两者都成功建立连接了,但不管是尝试往主题里发消息还是从主题消费消息,完全没有任何反应。我已经确认目标主题是创建成功的,而且Kafka容器启动时日志里弹出了一段警告信息,我不确定这是不是导致问题的根源,先把这段日志贴出来:
[2024-05-20 14:32:40,797] WARN [RequestSendThread controllerId=1] Controller 1's connection to broker kafka:9092 (id: 1 rack: null) was unsuccessful (kafka.controller.RequestSendThread) 2024-05-20 16:32:40 java.io.IOException: Connection to kafka:9092 (id: 1 rack: null) failed. 2024-05-20 16:32:40 at org.apache.kafka.clients.NetworkClientUtils.awaitReady(NetworkClientUtils.java:71) 2024-05-20 16:32:40 at kafka.controller.RequestSendThread.brokerReady(ControllerChannelManager.scala:298) 2024-05-20 16:32:40 at kafka.controller.RequestSendThread.doWork(ControllerChannelManager.scala:251) 2024-05-20 16:32:40 at org.apache.kafka.server.util.ShutdownableThread.ru...
有没有大佬能帮忙分析下,这段日志里的连接失败警告是不是和我遇到的生产消费无响应问题有关?或者还有其他可以排查的方向吗?
备注:内容来源于stack exchange,提问作者NeoChiri
相关产品推荐
相关产品推荐

