Kafka API获取非compacted topic总消息数

Posted 大数据Kafka技术分享

tags:

篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了Kafka API获取非compacted topic总消息数相关的知识，希望对你有一定的参考价值。

目前Kafka并没有提供直接的工具来帮助我们获取某个topic的当前总消息数，需要我们自行写程序来实现。下列代码可以实现这一功能，特此记录一下：

/**

以上是关于Kafka API获取非compacted topic总消息数的主要内容，如果未能解决你的问题，请参考以下文章

Kafka Log Compaction无法启动

KafkaKafka Log compaction 介绍

豆瓣电影API，包括豆瓣电影搜索、电影信息、评论、Top250等

Kafka压缩

Kafka-压缩算法

如何使用 JAVA API 从 Kafka 获取每个主题的消息数量 [重复]