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 打赏 0
回答交流
Markdown
请输入正文
提交
相关推荐
从postgresql 到kafka的实时逻辑同步，有哪些比较稳定的工具吗？
回答 2
开源方案Debezium可以了解一下。可以稳定运行在生产环境。
执行Kafka Topic 删除操作删除
回答 1
已采纳
可能是Broker目录存储的数据太多，然后导致加载时间过长。server.log日志还有详细点的吗
Flume可以正常连接kafka但是发送消息失败
回答 1
已采纳
1、查看Kafka服务是否正常。2、Flume连接Kafka地址是否正常。3、Flume发送超过Kafka大小限制。
ogg同步数据到kafka，topic中查不到
回答 2
topic名称不正确。检查kafka.props配置文件中定义的topicMappingTemplate是否正确。topic名称必须与目标端Kafka集群中存在的topic名称一致。数据格式不正确。检
kafka无法正常关闭
回答 1
已采纳
顺序搞反了，先关闭kafka，再关闭zookeeper试试
[KAFKA-20001]kafka认证失败导致无法启动
回答 1
已采纳
排查是不是以下原因造成的：1、账号被锁定导致认证失败。2、kafka账号密码错误导致认证失败。
kafka过来的topic类似a-a a-b a-c 这个格式,如何能不用一个个加入到logstash.conf 就能进行分类筛选?
回答 1
不会路过
多个平台MySQL数据库到单套kafka集群通过canal做同步，这个架构怎么搭建比较好?
回答 3
已采纳
kafka至少三节点的集群，硬盘要速度快，容量大，kafka里java相关的参数肯定要调整。另外最好考虑增量模式，全量模式可能会浪费磁盘空间。
大佬们 说说Kafka 有啥使用场景了 对这个东西定位不好啊
回答 1
当消息队列使用较为多，可以用作应用解耦。异步处理。消峰填谷。但是一般业务量不大的话，直接读写数据库更加好。否则进他是一个步骤，出他又是一个步骤。然后再写库。中间也有消耗。
执行 Kafka Topic 删除操作报错KAFKA-30001
回答 1
已采纳
可能原因1、客户端命令连接zookeeper地址错误2、Kafka服务异常Kafka部分节点处于停止状态3、Kafka服务端配置禁止删除4、Kafka配置自动创建，且Producer未停止
问题信息
请登录之后查看
邀请回答
暂无人订阅该标签，敬请期待~~
