2017-06-20 219 views
0

我有2名消费者说,C1属于组G1和C2属于组G2。 我有一个主题测试100条消息。 c1已读取消息并启用自动提交。 现在,如果我开始C2应该开始消费偏移0?如果是这样,我不能够消耗不同的组,从开始的消息多的消费者从同一主题的消费

回答

0

消费者偏移是独一无二的,由消费者控制。

在你的情况下,由于消费者对两种不同的组消耗相同的话题,因为没有偏移储存在任何地方,因此新的消费行为将取决于auto.offset.reset配置。如果设置为最小,则新消费者将从主题的开头(最小)开始或从主题的末尾(最大)开始。

+0

消费者在不同的群体有自己犯下的偏移量保持独立RYT? – codehacker

+0

每位消费者分别维护他们的抵消额。即使他们在同一组。还有一个单独的主题叫做__consumer_offset主题,您可以在每个分区中找到每个分区提交的偏移量。 –

+0

某个主题的每个分区都可以被特定组中的一个消费者使用,但如果它们位于不同的组中,则可以被多个消费者使用。 –

相关问题