2
我正在經歷卡夫卡，我明白主題將被劃分爲有序的分區序列。卡夫卡消費者是否應該從所有分區消費才能獲得完整的消息？
由於主題是分區的，消費者是否應該從所有分區中消費，以獲得完整的消息？如果是這樣，誰的責任是從所有消息中完整地傳達信息？
A
回答
2
將每個完整的消息全部寫入單個分區中的單個偏移量。只要使用任何可用的消費者API從任何一個分區讀取單個消息，就可以確保獲得完整的信息。
查看Kafka site瞭解更多信息
相關問題
- 1. 如何關閉卡夫卡消費者一旦消費完所有消息？
- 2. 卡夫卡消費者不消費
- 3. 消費者沒有從卡夫卡消費者提交的消息10消費者
- 4. 消費消費使用卡夫卡消費者 - Java
- 5. 如何從生產者消費卡夫卡的消費者？
- 6. 卡夫卡gruop消費者
- 7. 卡夫卡python消費者開始時讀取所有消息
- 8. 消費和生產特別是卡夫卡分區的消息？
- 9. 卡夫卡消費者不是從
- 10. 在卡夫卡消費活的消息
- 11. 消費者在卡夫卡消費的消息有哪些方式？
- 12. 當消費者的分區多於消費者時，卡夫卡消息如何消耗？
- 13. 在卡夫卡，如何讓消費者從本地分區消費？
- 14. 使卡夫卡消費者在訂閱之前消費現有消息
- 15. 卡夫卡消費者沒有消費數據
- 16. 簡單的卡夫卡消費者沒有收到消息
- 17. 卡夫卡10.2新消費者與舊消費者
- 18. 卡夫卡消費羣體和分區
- 19. 卡夫卡消費者/生產者API
- 20. 簡單的卡夫卡消費者消息傳遞重複
- 21. 春天卡夫卡不支持大消息的消費者
- 22. 卡夫卡消費者中的控制消息偏移量
- 23. 卡夫卡消費者沒有獲取所有郵件
- 24. Spark Streaming中的卡夫卡消費者
- 25. 雲中的卡夫卡消費者
- 26. 卡夫卡分區和消費者羣至少一次消息傳遞
- 27. 匹配卡夫卡消費者和生產者分區
- 28. 卡夫卡消費者閱讀並行消息
- 29. 卡夫卡消費者 - 接收消息不一致
- 30. 爲什麼卡夫卡消費者不聽第一條消息？
感謝Chris快速回復。有任何我可以看一看清晰例子的文檔嗎？我正在瀏覽kafka文檔，幾段後我就迷路了 – Nag