2017-06-20 181 views
0

我有2名消費者說,C1屬於組G1和C2屬於組G2。 我有一個主題測試100條消息。 c1已讀取消息並啓用自動提交。 現在,如果我開始C2應該開始消費偏移0?如果是這樣,我不能夠消耗不同的組,從開始的消息多的消費者從同一主題的消費

回答

0

消費者偏移是獨一無二的,由消費者控制。

在你的情況下,由於消費者對兩種不同的組消耗相同的話題,因爲沒有偏移儲存在任何地方,因此新的消費行爲將取決於auto.offset.reset配置。如果設置爲最小,則新消費者將從主題的開頭(最小)開始或從主題的末尾(最大)開始。

+0

消費者在不同的羣體有自己犯下的偏移量保持獨立RYT? – codehacker

+0

每位消費者分別維護他們的抵消額。即使他們在同一組。還有一個單獨的主題叫做__consumer_offset主題,您可以在每個分區中找到每個分區提交的偏移量。 –

+0

某個主題的每個分區都可以被特定組中的一個消費者使用,但如果它們位於不同的組中,則可以被多個消費者使用。 –

相關問題