我需要编写一个API来在java中显示消费者指标。我想使用Kafka管理客户端。我们有没有办法检索消费者指标信息?
我检查了管理客户端代码。我有卡夫卡消费类。我有消费者指标方法,但它不包含信息。
发布于 2019-07-29 06:22:22
Kafka使用者可以报告大量的metrics through JMX,您只需在代码中或通过命令行向您的使用者添加几个Java属性。例如,对于控制台消费者:
$ KAFKA_JMX_OPTS="-Dcom.sun.management.jmxremote=true -Dcom.sun.management.jmxremote.port=9398 -Dcom.sun.management.jmxremote.authenticate=false -Dcom.sun.management.jmxremote.ssl=false" kafka-console-consumer ...https://stackoverflow.com/questions/57241671
复制相似问题