生产者/消费者jmx度量

vqlkdk9b  于 2021-06-08  发布在  Kafka
关注(0)|答案(3)|浏览(464)

我被困在垃圾堆里了。看起来至少是这样。。。
我现在正试图从kafka控制台生产商那里生成jmx度量。我受够经纪人了。
我有一个collectd conf文件

  1. LoadPlugin java
  2. <Plugin java>
  3. <Plugin "GenericJMX">
  4. <MBean "kafka.producer.request-rate">
  5. ObjectName "kafka.producer:type=producer-metrics,clientId=([-.\w]+)"
  6. InstancePrefix "all"
  7. <Value>
  8. InstancePrefix "kafka-producer-request-rate"
  9. Type "gauge"
  10. Table false
  11. Attribute "request-rate"
  12. </Value>
  13. </MBean>
  14. <Connection>
  15. ServiceURL "service:jmx:rmi:///jndi/rmi://localhost:9999/jmxrmi"
  16. Host "tgarg"
  17. Collect "classes"
  18. Collect "garbage_collector"
  19. Collect "memory-heap"
  20. Collect "memory-nonheap"
  21. Collect "memory_pool"
  22. Collect "kafka.producer.request-rate"
  23. </Connection>
  24. </Plugin>
  25. </Plugin>

这对我来说很好,但最后我得到了

  1. collectd[552]: GenericJMXConfMBean: No MBean matched the ObjectName kafka.producer:type=producer-metrics,clientId=([-.w]+)

感谢您的帮助。
谢谢塔伦

ddarikpa

ddarikpa1#

运行时是否看到启用了jmx jps -v ? -Dcom.sun.management.jmxremote.port=9999 在你的箱子里应该看得见。
有关如何配置jmx的详细信息:http://docs.confluent.io/current/cp-docker-images/docs/operations/monitoring.html

plupiseo

plupiseo2#

我说过这是垃圾场的问题。collectd不明白([-.\w]+),我用*替换了它,用clientid替换了clientid(我的错)。
谢谢大家

w1e3prcc

w1e3prcc3#

在调用kafka_console_producer.sh之前,必须启用jmx setting jmx_port环境变量。像这样:

  1. JMX_PORT=9999 ./kafka-console-producer.sh --broker-list 127.0.0.1:9092 --topic topic1

有关详细信息,请参见bin/kafka-run-class.sh脚本。

相关问题