博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
Java 连接Kafka报错java.nio.channels.ClosedChannelExcep
阅读量:6295 次
发布时间:2019-06-22

本文共 2112 字,大约阅读时间需要 7 分钟。

hot3.png

Java 客户端连接Kafka报如下错误
bin/kafka-console-consumer.sh --zookeeper 255.255.255.255:2181 --topic eventbustopic[2015-06-02 16:23:04,375] WARN Fetching topic metadata with correlation id 0 for topics [Set(eventbustopic)] from broker [id:1,host:SOME_HOST,port:9092] failed (kafka.client.ClientUtils$)java.nio.channels.ClosedChannelException                                           at kafka.network.BlockingChannel.send(BlockingChannel.scala:100)               at kafka.producer.SyncProducer.liftedTree1$1(SyncProducer.scala:73)            at kafka.producer.SyncProducer.kafka$producer$SyncProducer$$doSend(SyncProducer.scala:72)    at kafka.producer.SyncProducer.send(SyncProducer.scala:113)                    at kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:58)            at kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:93)            at kafka.consumer.ConsumerFetcherManager$LeaderFinderThread.doWork(ConsumerFetcherManager.scala:66)    at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:60)         [2015-06-02 16:23:04,515] WARN Fetching topic metadata with correlation id 0 for topics [Set(eventbustopic)] from broker [id:0,host:SOME_HOST,port:9092] failed (kafka.client.ClientUtils$)java.nio.channels.ClosedChannelException                                           at kafka.network.BlockingChannel.send(BlockingChannel.scala:100)               at kafka.producer.SyncProducer.liftedTree1$1(SyncProducer.scala:73)            at kafka.producer.SyncProducer.kafka$producer$SyncProducer$$doSend(SyncProducer.scala:72)    at kafka.producer.SyncProducer.send(SyncProducer.scala:113)                    at kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:58)            at kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:93)            at kafka.consumer.ConsumerFetcherManager$LeaderFinderThread.doWork(ConsumerFetcherManager.scala:66)    at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:60)

是由于Kafka server.properties中的advertised.host.name 属性没有配置。这个属性代表客户端访问Kafka的地址。如果没配置默认是主机名。

转载于:https://my.oschina.net/chiyong/blog/522998

你可能感兴趣的文章
svg做自定义折线图表
查看>>
Koa源码分析(二) -- co的实现
查看>>
nohup和&的区别与关系
查看>>
UE4链接第三方库(lib和dll)
查看>>
phpstrom中让volt高亮显示
查看>>
macOS下nginx配合obs做推流直播.md
查看>>
数据结构——树
查看>>
浅析React之事件系统(二)
查看>>
Elixir 1.2带来多项功能增强和性能提升
查看>>
IPv6新形势下的安全解决方案
查看>>
红帽论坛北京站召开 设立亚太开放创新实验室
查看>>
函数式编程语言时代已经来临
查看>>
微软云数据库 Azure SQL DB Hyperscale如何实现超大规模存储和高可用?
查看>>
十年中文技术社区风雨之路 今晚4位老炮畅聊过去未来
查看>>
微软发起Java on Azure调查,呼吁Java社区积极参与
查看>>
SignalR Core尝鲜
查看>>
举重若轻的人人车移动端数据平台
查看>>
Swift 4.1增强了泛型、编译器和包管理器
查看>>
太多脚本将会毁掉持续交付
查看>>
应用性能监控方法一览
查看>>