2022-03-30
无法从Kafka中获取指定topic 消息
consumer 初始化成功，但是无法从 kafka 中获取指定topic 消息，使用 Storm、Spark、Flume编写 consumer代码来消费 kafka中指定topic的消息时，也发现消费不到任何数据。这是什么情况呢
我来答
添加附件
收藏
分享
问题补充
1条回答
默认
最新
没有日志不好判断具体原因，可能原因如下
1、Kafka 服务异常
2、Consumer中Zookeeper相关连接地址配置错误，导致无法消费
3、Consumer发生 ConsumerRebalanceFailedException 异常，导致无法消费
4、Consumer发生网络导致的ClosedChannelException 异常，导致无法消费
评论
有用 0
回答交流
提交
问题信息
请登录之后查看
邀请回答
暂无人订阅该标签，敬请期待~~
墨值悬赏