如何使用javaapi从kafka获取每个主题的消息数

xqkwcwgp  于 2021-06-08  发布在  Kafka
关注(0)|答案(1)|浏览(441)

这个问题在这里已经有答案了

java,如何在ApacheKafka中获取主题中的消息数(17个答案)
两年前关门了。
我想知道如何通过javaapi获得kafka中每个主题的消息数,我不知道我想使用下面文章中提到的命令行工具。你知道怎么做吗?
附言:我不想通过Kafka消费流来计算数量,我试图在一开始就计算这个数量(在从Kafka消费之前)
java,如何在ApacheKafka中获取一个主题中的消息数

gg0vcinb

gg0vcinb1#

使用新的 KafkaConsumer 你可以用 seekToBeginning(...) 以及 seekToEnd(...) 计算每个分区的最大偏移量和最小偏移量之差,并将这些数字相加。
如果你寻找,你不会消费信息。记住,seek是懒惰的,也就是说,你需要使用 position(...) 真正触发寻找。因为懒惰,两种方法都没有回报。然而, position(...) 将给出可以用于计算的偏移量。
看到了吗http://kafka.apache.org/0100/javadoc/index.html?org/apache/kafka/clients/consumer/kafkaconsumer.html

相关问题