卡夫卡總是一個消費者在一個組中消費主題消息

Question

我有兩個消費者服務器具有相同的組id訂閱相同的主題。 一個kafka服務器只運行一個分區。 據我所知，消息應該在這兩個消費者服務器中隨機消費。 但現在它似乎總是消費者服務器A消費消息，另一個不消費消息。如果我停止消費者服務器A，另一個會正常工作。 我期望他們可以隨意使用消息。

Answer 1

爲了能夠並行使用兩個使用者實例，您至少需要在主題中使用兩個分區。消費者將綁定到主題的一個或多個分區，並且具有相同groupId的其他消費者不會聲明已經有消費者綁定到他們的分區。如果消費者失敗/崩潰，分區將被釋放，然後被另一個消費者實例提取。