kafka用的别人的集群,我这边消费者连上去之后,消费不了之前已经存在的消息,我消费者在线的时候才能消费当前新的消息

心的方向 发表于: 2018-09-03   最后更新时间: 2018-09-03 14:35:13   3,101 游览

就是只有消费者在线才能消费消息,消费不了历史消息,我看了下文档,怀疑是我消费者连上去之后找不到消费者组的偏移量,而客户端默认配置就是找不到偏移量之后,就取消息的最大偏移量,所以消费不了消息,但是不知道怎么解决,还请指导一下,谢谢

发表于 2018-09-03
添加评论

你想像一下订报纸,在你没有订阅之前,报社根本就不知道你,当你订阅的这一刻,新的报纸才会发给你,老的报纸是不会给你的。如果你消费者关掉了,发报员依然会为你保留报纸,因为你已经在报社有名单了。

心的方向 -> 半兽人 5年前

恩,我已经订阅过了啊,订阅后离线了,在链接上,消费不了离线期间的消息,照理说消费者组应该会记录偏移量啊

半兽人 -> 心的方向 5年前

你的group.id要设置成固定的。

心的方向 -> 半兽人 5年前

group.id是固定的,配置文件里面写的

半兽人 -> 心的方向 5年前

那就不会出现这种情况的,你可以执行命令吗?
https://www.orchome.com/454
命令大全里有查询命令,你试下。

一个分区 只能有一个消费者,你down掉了后 会有其他的消费者补上,其他消费者 会提交新的偏移量

你的答案

查看kafka相关的其他问题或提一个您自己的问题