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

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







发表于: 19天前   最后更新时间: 19天前   游览量:119
上一条: 到头了!
下一条: 已经是最后了!

评论…


  • 你想像一下订报纸,在你没有订阅之前,报社根本就不知道你,当你订阅的这一刻,新的报纸才会发给你,老的报纸是不会给你的。如果你消费者关掉了,发报员依然会为你保留报纸,因为你已经在报社有名单了。
    不好意思,网络卡了,多提交了几次
  • 评论…
    • in this conversation