路生

0 声望

这家伙太懒，什么都没留下

个人动态
  • 半兽人 回复 路生 在 kafka入门介绍 中 ：

    a的offset，如果a恢复了，也会从b刚维护的offset开始，都是以最新的offset开始。

    3年前
  • 关注了用户 半兽人 · 3年前
  • 路生 回复 半兽人 在 kafka入门介绍 中 ：

    如果b这时候同时消费A和B，那消费A是从哪里开始呢？a之前维护的offset？还是b目前的offset？

    3年前
  • 赞了 路生 在 kafka入门介绍 的评论!

    这个offset只跟消费者组有关，按照你的例子来。消费者组中有a,b,c三个消费者。
    当它们同时运行之后，a消费A，b消费B，c消费C。总共维护3个offset你的理解是对的。
    这个时候，如果a消费者挂掉，kafka会进行消息平衡，将之前a消费者的A分区，分配给了b消费者。
    这时消费者b就会接着消费A分区。这时b就同时消费A和B了，c还是只消费C。

    3年前
  • 路生 回复 半兽人 在 kafka入门介绍 中 ：

    客户端宕机重启了。offset会不会丢失？

    3年前