kafka消费者启动报错
2024-10-18 20:19:41
报错信息:
WARN Fetching topic metadata with correlation id 14 for topics [Set(test)] from broker [BrokerEndPoint(2,ubuntu,9092)] failed (kafka.client.ClientUtils$)
WARN Fetching topic metadata with correlation id for topics [Set(test)] from broker [BrokerEndPoint(,ubuntu,)] failed (kafka.client.ClientUtils$)
java.nio.channels.ClosedChannelException
at kafka.network.BlockingChannel.send(BlockingChannel.scala:)
at kafka.producer.SyncProducer.liftedTree1$(SyncProducer.scala:)
at kafka.producer.SyncProducer.kafka$producer$SyncProducer$$doSend(SyncProducer.scala:)
at kafka.producer.SyncProducer.send(SyncProducer.scala:)
at kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:)
at kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:)
at kafka.consumer.ConsumerFetcherManager$LeaderFinderThread.doWork(ConsumerFetcherManager.scala:)
at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:)
^X[-- ::,] WARN Fetching topic metadata with correlation id for topics [Set(test)] from broker [BrokerEndPoint(,ubuntu,)] failed (kafka.client.ClientUtils$)
java.nio.channels.ClosedChannelException
at kafka.network.BlockingChannel.send(BlockingChannel.scala:)
at kafka.producer.SyncProducer.liftedTree1$(SyncProducer.scala:)
at kafka.producer.SyncProducer.kafka$producer$SyncProducer$$doSend(SyncProducer.scala:)
at kafka.producer.SyncProducer.send(SyncProducer.scala:)
at kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:)
at kafka.client.ClientUtils$.fetchTopicMetadata(ClientUtils.scala:)
at kafka.consumer.ConsumerFetcherManager$LeaderFinderThread.doWork(ConsumerFetcherManager.scala:)
at kafka.utils.ShutdownableThread.run(ShutdownableThread.scala:)
问题:可以非常明显的看到
这个主机名是ubuntu,这个名字在hosts文件中我没有配置映射,非常粗心的一个问题。
解决:在/etc/hosts文件中添加主机名和ip映射。
说明:这个kafka相互通信连接的时候是默认拿着主机名加端口号的,而我开始在hosts文件中映射的ip并不是使用的主机名,因为几台机器的主机名命名不规范,所以我的映射文件是统一命名py101、py102、py103这种。而kafka默认拿着主机名寻找映射信息,然而hosts文件中没有,故报错。
最新文章
- react-native-http请求后navigator导航跳转
- spread语法解析与使用
- 2014百度之星资格赛 1004:Labyrinth(DP)
- 基于Qt的遥感图像处理软件设计总结
- [转]JQuery.Ajax之错误调试帮助信息
- eclipse myeclipse zend studio 中去掉双引号中的斜体
- UIProgressView
- qt 程序启动参数 -qws
- 自写Date工具类
- r语言之散点图类型type参数
- pycharm运行scrapy
- 新的编辑工具IDE
- jenkins测试配置
- selenium中下拉框的定位
- 【liunx】Linux下的压缩和解压缩命令——jar
- SVM Kernel Functions
- Spark SQL metaData配置到Mysql
- java基础68 JavaScript城市联动框(网页知识)
- Android网络开发之WebKet引擎基础
- (转)No architectures to compile for (ONLY_ACTIVE_ARCH=YES, active arch=arm64, VA 解决办法