特别的人

0 声望

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

个人动态
  • 特别的人 回复 半兽人kafka入门介绍 中 :

    嗯嗯,懂了,多谢~也就是一个分区的数据是会被固定的一个消费者消费,只有该消费宕掉时候,该分区的消费者才会转变。

    5年前
  • 半兽人 回复 特别的人kafka入门介绍 中 :

    当消费者宕掉的时候,其他的消费者才能消费,始终是1个分区对应1个消费者。

    5年前
  • 半兽人 回复 特别的人kafka入门介绍 中 :

    我上面说的很清楚了吧,3个分区,4个消费者的情况,有1个消费者永远拿不到消息,1个分区只能被1个消费者消费。

    5年前
  • 特别的人 回复 半兽人kafka入门介绍 中 :

    一个分区的话,消息也是平均分配给A消费者组的3个consumer是吗?
    我看文章中写到“每个partition仅由同一个消费者组中的一个消费者消费到。并确保消费者是该partition的唯一消费者,并按顺序消费数据。”这里说的是“唯一消费者”,也就是说对于一个topic中的一个分区中的数据,是被订阅该topic的消费者组中固定的一个consumer消费是吗?是不能改变的?

    5年前
  • 半兽人 回复 特别的人kafka入门介绍 中 :

    consumer组内的成员平分消息,如果你有3个分区,A消费组有4个消费者,那么将有一个消费者永远拿不到消息。 每个分区都是顺序的,但是因为你的消费者程序处理消息的速度不一样,所以最终无法保证顺序,如果你想保证顺序,那只能1个分区。

    5年前