Java，如何获取Apache Kafka中某个主题的消息数
我正在使用apache kafka进行消息传递。我已经用Java实现了生产者和消费者。我们如何获取主题中的消息数量？
回答：
从消费者的角度来看，想到此的唯一方法是实际消费消息并计数。
Kafka代理公开了自启动以来收到的消息数量的JMX计数器，但是您不知道已经清除了其中的多少。
在最常见的情况下，最好将Kafka中的消息视为无限流，而获得当前磁盘上保留的离散值并不重要。此外，在与一组经纪人进行交易时，事情变得更加复杂，这些经纪人都具有主题中消息的子集。
以上是 Java，如何获取Apache Kafka中某个主题的消息数 的全部内容， 来源链接： utcz.com/qa/424568.html
