卡夫卡新手
我想知道有没有办法使用 java-api 获取 kafka-metrics。这是我所说的 kafka-metrics 的意思:
- 主题列表
- 每个主题分区中的消息数(包括起始偏移量、结束偏移量)
- 经纪人名单
- 假设我使用 0.9 消费者 API 并让 kafka 管理我的消费者偏移量，每个消费者的偏移量
我意识到，可能只有其中一些可用，并且它们可能通过不同的类或方法可用。这就是我为每个要点编号的原因。
最佳答案
KafkaConsumer listTopics() 方法将解决第一个问题。
KafkaConsumer metrics() 将为您提供该消费者的指标。
KafkaProducer metrics() 将为您提供该生产者的指标。
希望对您有所帮助!
关于java - 有没有办法使用 Java 收集 Kafka 指标？，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/35067397/