我有一個生產者寫消息到主題/分區。爲了維護訂購,我想單個分區,我想讓12個消費者閱讀這個單一分區的所有消息(沒有消費者組,所有消息都應該發給所有消費者)。這是可以實現的嗎?我讀過一些論壇,只有一位消費者可以閱讀每個分區。卡夫卡多個消費者的分區
6
A
回答
13
您可以使用SimpleConsumer
來實現您正在詢問的內容 - 沒有消費羣體,所有消費者都可以閱讀單個分區。但是,這種方法意味着您必須自己處理抵消存儲和代理失敗處理。
另一種選擇是使用具有不同消費羣體的高級消費者(您可以爲每個消費者分配一個隨機UUID)。通過這種方式,您可以爲所有消費者消費一個主題/分區,並能夠提交抵消和處理代理中斷。
「只有一個消費者可以消費某個主題/分區」的規則僅適用於消費者組,例如,只有一個IN GROUP消費者可以同時使用一個主題/分區。
0
如果您在同一個分區上有多個使用者,那麼它會勝過維護排序的初始要求。 雖然,你會訂購存儲,但消費將是無序的。確保你確實沒問題。如果是的話,你可以把每個消費者視爲一個不同的消費羣體。
相關問題
- 1. 卡夫卡gruop消費者
- 2. 卡夫卡消費者不消費
- 3. 匹配卡夫卡消費者和生產者分區
- 4. 卡夫卡消費羣體和分區
- 5. 卡夫卡消費者/生產者API
- 6. 春季卡夫卡消費者:有沒有使用卡夫卡0.8從多個分區讀取的方法?
- 7. 卡夫卡消費者和分區查詢
- 8. 卡夫卡 - 主題&分區和消費者
- 9. 當消費者的分區多於消費者時,卡夫卡消息如何消耗?
- 10. 如何從生產者消費卡夫卡的消費者?
- 11. Spark Streaming中的卡夫卡消費者
- 12. 雲中的卡夫卡消費者
- 13. 在卡夫卡,如何讓消費者從本地分區消費?
- 14. 消費消費使用卡夫卡消費者 - Java
- 15. 卡夫卡消費者 - 消費者流程和主題分區與主題分區的關係如何?
- 16. 卡夫卡10.2新消費者與舊消費者
- 17. 復位消費者在卡夫卡0.10
- 18. 無法創建卡夫卡消費者
- 19. 卡夫卡消費者同步行爲
- 20. 問題在消費者卡夫卡
- 21. 暫停高級卡夫卡消費者
- 22. 卡夫卡消費者不是從
- 23. 卡夫卡消費者行爲
- 24. 關閉卡夫卡消費者
- 25. 卡夫卡消費者行爲
- 26. 春季集成卡夫卡消費者
- 27. 如何暫停卡夫卡消費者?
- 28. 卡夫卡消費者 - Java客戶端
- 29. 卡夫卡消費者與JAVA
- 30. 卡夫卡0.90消費者堅持
如果我爲每個消費者使用獨特的消費者羣組ID,我會從單個分區讀取每個消費者的所有消息?即類似的代碼.. props.put(「group.id」,KafkaProperties.groupId); – skumar
是的,如果您的單個分區的主題有1000條消息,則擁有不同消費羣的所有消費者都將讀取1000條消息。 – serejja
您可以舉一些方法1(處理抵消和經紀人failer)和方法2(將randow uui分配給每個消費者)的例子嗎? – skumar