当前位置:   article > 正文

kafka用java编写消费者 消费不到数据_java 配置了kafaka后消费端不消费数据

java 配置了kafaka后消费端不消费数据

这是报的异常:
Caused by: java.nio.channels.UnresolvedAddressException
at sun.nio.ch.Net.checkAddress(Net.java:101)
at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:622)
at org.apache.kafka.common.network.Selector.connect(Selector.java:192)
… 15 more
2018-12-06 21:12:41,645 DEBUG org.apache.kafka.clients.NetworkClient.maybeUpdate() - Initialize connection to node hadoop01:9092 (id: 1 rack: null) for sending metadata request
2018-12-06 21:12:41,645 DEBUG org.apache.kafka.clients.NetworkClient.initiateConnect() - Initiating connection to node hadoop01:9092 (id: 1 rack: null)
2018-12-06 21:12:41,645 DEBUG org.apache.kafka.clients.NetworkClient.initiateConnect() - Error connecting to node hadoop01:9092 (id: 1 rack: null)
java.io.IOException: Can’t resolve address: hadoop01:9092
at org.apache.kafka.common.network.Selector.connect(Selector.java:195)
at org.apache.kafka.clients.NetworkClient.initiateConnect(NetworkClient.java:764)
at org.apache.kafka.clients.NetworkClient.access 600 ( N e t w o r k C l i e n t

声明:本文内容由网友自发贡献,不代表【wpsshop博客】立场,版权归原作者所有,本站不承担相应法律责任。如您发现有侵权的内容,请联系我们。转载请注明出处:https://www.wpsshop.cn/w/小舞很执着/article/detail/935437
推荐阅读
相关标签
  

闽ICP备14008679号