这家伙太懒,什么都没留下
群里问过大佬了,这个标注一下,一个消息只会放在一个分区里面。 防止大家和我一样理解有偏差。
1,生产者把消息发送给集群之后,任务完成了,他不需要知道谁是消费者。2、消费者每个人维护自己的offset。
请教您一个问题,假如我的一个topic 有三个分区,那么生产者生产一条消息后会均匀的分布到这三个分区,那么每个分区都有对这条消息的偏移量。那么假设我的消费者组里面有三个消费者ABC分别对应三个分区 ,那么a消费了这条消息后偏移量+1,那第二个分区中的此条消息不是还存在吗,这种情况该三个消费者是如何维护偏移量的呢?谢谢。