Apache Kafka如何將消息發送給多個消費者組？

Question

在Kafka documentation：

卡夫卡不同的方式處理這個。我們的主題分爲一組 完全訂購的分區，每個分區在任何給定時間都由一個消費者 消費。這意味着消費者在每個 分區中的位置只是一個整數，下一個消息的偏移量將消耗到 。這使得所消耗的狀態非常小，每個分區只有一個數字。這個狀態可以是週期性的 檢查點。這使消息確認相當於 非常便宜。

然而，以下是同一個文檔中的快速入門指南，我很容易能夠：

1. 只有一個分區
2. 啓動控制檯製片
3. 推一個創建一個話題很少的消息
4. 啓動消費者消費--from-beginning
5. 開始另一個消費者--from-beginning

並且兩個消費者都成功從同一分區消費。

但是，這似乎與上述文件不符？

Answer 1

當使用不同的消費羣體時，消費者可以輕鬆使用相同的分區。您可以將羣組標識視爲消費卡夫卡主題的不同應用程序。多個不同的應用程序可能想要以不同的方式使用Kafka主題中的數據，因此不會與其他應用程序發生衝突。這就是爲什麼兩個消費者可能消費一個分區（實際上是兩個消費者如何消費一個分區的唯一方式）。

當你啓動一個控制檯消費者時，它隨機生成一個組ID（link），因此這些消費者正在做我剛剛寫的東西。