0
A
回答
0
KafkaConsumer API提供的接口可以幫助您。有beginningOffsets(Collection<TopicPartition> partitions)
和endOffsets(Collection<TopicPartition> partitions)
。您可以針對主題中的所有分區調用這些方法,然後查找每個主題分區的結束偏移量和起始偏移量之間的差異。然後聚合所有主題分區。這應該會爲您提供主題中的消息數量。 (reference)
1
什麼瓦希德sayd可能是一個解決方案,但你也可以使用下面的一個:
bin/kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list localhost:9092 --topic --time -1
,那麼你必須要總結的計數值。
無論如何,如果日誌壓縮處於活動狀態,請考慮我的和vahid解決方案不起作用,因爲在這種情況下,偏移量之間可能存在一些「間隙」,因此只計算差異並不能爲您提供消息的數量。
相關問題
- 1. 以編程方式檢查fixnum大小
- 2. 如何以編程方式查找Azure實例角色大小?
- 3. 如何以編程方式查找當前LOH的大小?
- 4. 無法從cmd實用程序和以編程方式刪除Kafka主題(Java)
- 5. 以編程方式查找openCL設備支持的最大工作組大小
- 6. 以編程方式調整大小NSSplitView
- 7. 以編程方式更改RatingBar大小?
- 8. 以編程方式更改TChart大小
- 9. 以編程方式膨脹AppCompat主題
- 10. 以編程方式更改awesomewm主題
- 11. 以編程方式應用主題
- 12. 以編程方式應用Powerpoint主題
- 13. 如何以編程方式查找我iphone應用程序的大小?
- 14. 如何找到MemoryCache的大小,最好以編程方式?
- 15. 查看字節中的Kafka主題的大小
- 16. 以編程方式查找網絡掩碼中的主機數
- 17. 以編程方式與主廚一起查找AWS公共DNS
- 18. 以編程方式設置列表視圖的標題大小
- 19. 如何以編程方式獲得UINavigationBar標題的大小?
- 20. 如何以編程方式查找javac.exe?
- 21. 以編程方式查找GridView行
- 22. 以編程方式查找地區
- 23. 以編程方式使用大小類設置字體大小
- 24. jQuery UI可調整大小:以編程方式設置大小?
- 25. Android:根據屏幕大小以編程方式調整大小
- 26. Swift:在不同的設備上以編程方式查找元素的大小
- 27. 如何以編程方式檢查Android上SMS消息大小
- 28. 以編程方式查找iphone內存的問題
- 29. 如何以編程方式查找EJB的JNDI查找名稱?
- 30. 以編程方式設置TextView大小使其小於wrap_content