这个问题在这里已经有答案了：
java，如何在ApacheKafka中获取主题中的消息数（17个答案）
两年前关门了。
我想知道如何通过javaapi获得kafka中每个主题的消息数，我不知道我想使用下面文章中提到的命令行工具。你知道怎么做吗？
附言：我不想通过Kafka消费流来计算数量，我试图在一开始就计算这个数量（在从Kafka消费之前）
java，如何在ApacheKafka中获取一个主题中的消息数
这个问题在这里已经有答案了：
java，如何在ApacheKafka中获取主题中的消息数（17个答案）
两年前关门了。
我想知道如何通过javaapi获得kafka中每个主题的消息数，我不知道我想使用下面文章中提到的命令行工具。你知道怎么做吗？
附言：我不想通过Kafka消费流来计算数量，我试图在一开始就计算这个数量（在从Kafka消费之前）
java，如何在ApacheKafka中获取一个主题中的消息数
1条答案
按热度按时间gg0vcinb1#
使用新的
KafkaConsumer你可以用seekToBeginning(...)以及seekToEnd(...)计算每个分区的最大偏移量和最小偏移量之差，并将这些数字相加。如果你寻找，你不会消费信息。记住，seek是懒惰的，也就是说，你需要使用
position(...)真正触发寻找。因为懒惰，两种方法都没有回报。然而，position(...)将给出可以用于计算的偏移量。看到了吗http://kafka.apache.org/0100/javadoc/index.html?org/apache/kafka/clients/consumer/kafkaconsumer.html