Kafka消费时报错：Producer connection to xxx:9092 unsuccessful
使用kafka消费数据时报Producer错误，具体错误如下：
kafka.producer.SyncProducer:103 Producer connection to xxx:9092 unsuccessful
java.nio.channels.ClosedByInterruptException
at java.nio.channels.spi.AbstractInterruptibleChannel.end(AbstractInterruptibleChannel.java:202)
at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:659)
at kafka.network.BlockingChannel.connect(BlockingChannel.scala:57)
at kafka.producer.SyncProducer.connect(SyncProducer.scala:141)
at kafka.producer.SyncProducer.getOrMakeConnection(SyncProducer.scala:156)
at kafka.producer.SyncProducer.kafka$producer$SyncProducer$$doSend(SyncProducer.scala:68)
at kafka.producer.SyncProducer.send(SyncProducer.scala:112)
at kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:53)
at kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:88)
at kafka.consumer.ConsumerFetcherManager$LeaderFinderThread.doWork(ConsumerFetcherManager.scala:66)
at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:51)
xxx是kafka集群中的某一个节点主机名，虽然kafka消费者没有配置从此主机上取数据，但必须能够识别此主机名，因此在本机hosts文件里面修改(C:\Windows\System32\drivers\etc\hosts)，增加域名映射：
192.168.0.120 xxx
问题解决。
最新文章
- yii中的cookie的发送和读取
- [Usaco2015 Feb]Censoring（bzoj 3942）
- xcode 编译opencv ios容易出现的错误
- 2015弱校联盟(1) - B. Carries
- Oracle SQL*plus常用的命令和函数
- opensuse安装mysql-workbench
- CSAPP--存储器及程序的局部性
- HDU 3376 && 2686 方格取数 最大和 费用流裸题
- nova创建虚拟机源码分析系列之八 compute创建虚机
- Python 目录整理
- 仿照 ButterKnife 的 Android 注解实例
- 多线程爬虫爬取详情页HTML
- linux简单的安全防护
- ssh 管理 linux登录远程服务器
- 整理：iOS 短信与电话事件的获取
- PHP中使用CURL模拟登录并获取数据实例
- [翻译] SWTableViewCell
- HDU 2307 贪心之活动安排问题
- 使用BabeLua3.x在cocos2d-x中编辑和调试Lua
- BZOJ1834：[ZJOI2010]网络扩容——题解