如何創建一個kafka非持久性主題

Question

有沒有辦法讓一個kafka主題不持久？我打算在單個主題中使用多個消費者，但我不希望所有消費者都收到相同的消息。

Answer 1

在卡夫卡模擬隊列的行爲，所有的消費者將在相同的consumer group。

See the kafka docs for more information

消費者

消息歷來有兩種型號：排隊和發佈 - 訂閱。 在隊列中，消費者池可能會從服務器讀取消息，並且每個消息都會轉到其中一個消息;在發佈 - 訂閱消息是 廣播給所有消費者。卡夫卡提供了一個單一的消費者抽象 ，概括了這兩個消費羣體。消費者用消費者組名稱標記 自己，並且發佈到 主題的每個消息被遞送到每個訂閱消費者組內的一個消費者實例。消費者實例可以位於不同的進程中，也可以位於不同的計算機上。

如果所有使用者實例具有相同的使用者組，那麼此 的工作方式與對消費者的傳統隊列平衡負載相同。

如果要控制當消息從日誌中刪除，你可以在主題配置設置retention.ms或retention.bytes。請注意，這些參數會刪除一條消息，無論它是否已被消費