kafka 消费者消费不到数据

[root@hzctc-kafka-5d61 ~]# kafka-run-class.sh kafka.tools.ConsumerOffsetChecker --group sbs-haodian-message1 --topic Message --zookeeper 10.1.5.61:2181
[2018-04-18 16:43:43,467] WARN WARNING: ConsumerOffsetChecker is deprecated and will be dropped in releases following 0.9.0. Use ConsumerGroupCommand instead. (kafka.tools.ConsumerOffsetChecker$)
Exiting due to: org.apache.zookeeper.KeeperException$NoNodeException: KeeperErrorCode = NoNode for /consumers/sbs-haodian-message1/offsets/Message/8.

用kafka的时候用命令查看消费组消费情况报这个错误其他的消费组是正常的哪位大神知道这是什么原因导致的

我在消费操作的时候加了缓存锁每次poll操作之后的间隔时间不确定可能是10S或者20S或者30S 不过我的sessiontimeiut设置了90s。这个会有什么影响吗

写回答
好问题 0 提建议
追加酬金
关注问题
分享
邀请回答
编辑收藏删除
收藏举报

2条回答

关注

码龄粉丝数原力等级 --

被采纳

被点赞

采纳率
发生s 2018-04-18 16:16
关注
新版本的offset信息保存在kafka的一个topic里面

解决无用
评论打赏
分享
举报

评论

按下Enter换行，Ctrl+Enter发表内容

报告相同问题？

关注问题

kafka拉取不到数据 java kafka 分布式有问必答
2022-02-16 19:32

回答 4 已采纳重新开一个topic，然后先启动consumer，再启动producer，再发消息，你这个可能是consumer已经在broker里有了自己的offset，就会读不到之前producer发送到brok
kafka消费者创建不了 java kafka linux
2022-08-23 10:01

回答 1 已采纳同一个消费组能同时消费的消费者数量和topic的分区数有关，估计是你的topic只有两个分区所以使用相同的groupid只有两个消费者在消费，加一个分区就好
Kafka消费者消费信息经常接收不到 java
2022-12-21 00:45

回答 1 已采纳这篇博客也许可以解决你的问题👉 ：kafka消费者从kafka读取信息
kafka用java编写消费者 消费不到数据
2018-12-07 21:12

吃提子要吐皮的博客 Caused by: java.nio.channels.UnresolvedAddressException at sun.nio.ch.Net.checkAddress(Net.java:101) at sun.nio.ch.SocketChannelImpl.connect(SocketChannelImpl.java:622) at org.apache.kafka.com...
flink消费kafka数据延迟 flink postgresql scala 有问必答
2022-01-28 09:47

回答 1 已采纳那最后写入到库了吗，如果写不进去，上游kafka肯定会延迟越来越大的，可以在sink里多打印下错误，或者设置写入超时时间，问题应该在写入
kafka取不到监听数据 jar 有问必答
2021-04-20 10:49

回答 3 已采纳 https://gewu.pcwanli.com/front/article/10619.html
Springboot集成kafka，应用很卡，消费很慢 java kafka spring boot
2022-10-25 09:26

回答 5 已采纳感觉消息堆积有点厉害，查一下代码，是因为什么原因导致消息一直没被消费。如果只是前端数据，可以丢弃的话，把队列清空，看看还会不会卡？
kafka消费者参数详解 java读取不到消费者数据
2019-07-05 18:33

菜鸟好好吃的博客程序运行中，生产者可以成功生产数据，消费者却一直拿不到存储的数据，运行消费者命令：kafka-console-consumer --bootstrap-server 127.0.0.1:9092 --topic saturn-importer-br-job-kafka-test --from-beginning ...
一台机器可以即可以充当kafka消费者又充当kafka生产者吗？ java kafka
2022-01-10 15:46

回答 3 已采纳 消费者和生产者与机器无关，这是不同的概念，消费者与生产者只是在Kafka中的角色，不同角色干不同的事情
kafka可以生产无法消费的问题 java kafka
2022-06-11 10:41

回答 1 已采纳给你个例子，是可以收发的。验证通过再和你的对比一下，你应该哪里配错了。 springboot集成kafka、消息发送、消费使用_‘’小磊的博客-CSDN博客_spri
flink消费kafka flink java kafka 有问必答
2021-07-02 11:07

回答 2 已采纳对kafka来说，只要这条数据发出去了，就算消费了，你消费者怎么处理，和kafka无关了。对消费者来说，你只需要消费下一条就行了。至于偏移量，你第一次消费的时候，是要发送偏移的，这个你消费者要本地
【项目实战】Java 开发 Kafka 消费者
2023-07-14 08:53

激流丶的博客 Kafka 消费者是使用 Apache Kafka 消息队列系统的应用程序，它们用于从 Kafka 主题（topics）中读取消息。消费者订阅一个或多个主题，并从这些...消费者是 Kafka 中的重要组成部分，用于实现可靠的消息传递和数据处理。
kafka如何获取到发送失败的数据 java kafka 有问必答
2021-07-27 10:36

回答 1 已采纳 kafka调用send方法发送数据后会返回一个ListenableFuture 这个ListenableFuture可以添加callback进行监听d
Kafka消费不到数据
2023-05-16 10:07

wildding的博客看logdir的目录，换个目录或者删除目录中的数据，本机是 rm -rf datas/* (方法2：停止zookeeper： zk.sh stop 查看conf/zoo.cfg的。：zookeeper报错日志可以在 logs里xxxx.out中查看)：kafka报错日志可以在 logs里 ...
Kafka 消费者远程读不到数据
2019-08-28 14:31

香山上的麻雀1008的博客 kafka远程消费不到数据,但是也不报错远程主机用telnet命令去测试kafka以及zookeeper节点的9200端口以及2181端口都畅通。这是因为没有配置advertised.host.name，所以kafka获取ip信息的时候使用的是java.net....
没有解决我的问题, 去提问

悬赏问题

¥50 有数据，怎么建立模型求影响全要素生产率的因素
¥50 有数据，怎么用matlab求全要素生产率
¥15 TI的insta-spin例程
¥15 完成下列问题完成下列问题
¥15 C#算法问题, 不知道怎么处理这个数据的转换
¥15 YoloV5 第三方库的版本对照问题
¥15 请完成下列相关问题！
¥15 drone 推送镜像时候 purge: true 推送完毕后没有删除对应的镜像,手动拷贝到服务器执行结果正确在样才能让指令自动执行成功删除对应镜像，如何解决？
¥15 求daily translation（DT）偏差订正方法的代码
¥15 js调用html页面需要隐藏某个按钮