很奇怪,我無法在網上輕鬆找到這些信息,但我無法。所以,我的問題是我有一個卡夫卡話題。我希望兩個彼此獨立的消費者組消費這個主題的消息。所以,我想要的是兩個消費者羣體都能夠看到並消費彼此獨立的所有消息。爲了更加清楚,我不想讓一個消費者組消費一些消息,並且一些消息被另一個消費組消費;不,我希望2個組消耗消息,就好像另一個組不存在一樣。Kafka:多個獨立消費者羣體可以消費一個主題嗎?
1
A
回答
1
是的,多個消費者/消費者組可以獨立使用來自主題的消息。每個消費者(或消費者羣體)的抵消額分開保存。您可以運行kafka.tools.ConsumerOffsetChecker可以查看任何主題的任何消費羣的偏移量如下圖所示:
bin/kafka-run-class.sh kafka.tools.ConsumerOffsetChecker --topic test --zookeeper localhost:2181 --group testgroup
注意(這抵消),其中消費者開始讀取從主題的消息被自動控制.offset.reset配置。如果設置爲最小,則新消費者將從主題的開頭(最小)開始或從主題的末尾開始(如果這被設置爲最大)。
2
是的,單獨的消費羣體是完全獨立的,所以他們都看到所有消息。
資源分區(主題/分區)只發生在組內。
相關問題
- 1. 在Rust消費者中消費多個Kafka主題
- 2. kafka中的多個消費羣體
- 3. Apache Kafka消費羣體和簡單消費者
- 4. 單個生產者到多個消費者(相同的消費者羣體)
- 5. Kafka關於消費羣體的問題
- 6. 如何在Golang中創建一個kafka消費者羣體?
- 7. pipelinedb消費kafka主題
- 8. Kafka消費者控制檯訂閱多個主題
- 9. spring-cloud-stream-kafka不尊重單個消費者的羣體
- 10. 多的消費者從同一主題的消費
- 11. 多個消費羣體消費者如何在卡夫卡的同一主題上跨越分區工作?
- 12. 多的消費者在同一消費羣
- 13. 生產者 - 消費者多個生產者多個隊列單個消費者
- 14. Apache Kafka - iOS消費者
- 15. kafka消費者上的AssertionError
- 16. Apache Kafka:消費者狀態
- 17. clj-kafka - 消費者空
- 18. Kafka消費羣集環境抵消
- 19. Kafka高級消費者:分區可以有多個線程使用它嗎?
- 20. Apache Kafka:如何找出一個話題的消費羣?
- 21. Kafka - 同一羣組/主題上的多個消費者(只有一個活動人)
- 22. Apache Kafka如何將消息發送給多個消費者組?
- 23. 如何在多個消費者閱讀相同的kafka消息
- 24. 永久運行kafka消費者(新消費者API)
- 25. 使用新消費者API刪除kafka消費者偏移量
- 26. 製片人 - 消費者Scenerio。我有一個生產者和多個消費者
- 27. BlockingCollection多個消費者
- 28. MassTransit多個消費者
- 29. ActiveMQ一個生產者多消費者
- 30. spring-kafka(未集成)消費者不消費消息
我不確定我是否理解「資源分區(主題/分區)只在組內發生」。每個主題的分區和複製不能改變每個消費者組;這是您創建主題本身時決定的。 – user1888243
我的意思是將分區分配給消費者,因爲在一個組中只能將一個消費者分配給一個分區。 –