生产者/消费者jmx度量

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

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

LoadPlugin java
<Plugin java>
    <Plugin "GenericJMX">
        <MBean "kafka.producer.request-rate">
            ObjectName "kafka.producer:type=producer-metrics,clientId=([-.\w]+)"
            InstancePrefix "all"
            <Value>
                InstancePrefix "kafka-producer-request-rate"
                Type "gauge"
                Table false
                Attribute "request-rate"
            </Value>
        </MBean>
        <Connection>
            ServiceURL "service:jmx:rmi:///jndi/rmi://localhost:9999/jmxrmi"
            Host "tgarg"
            Collect "classes"
            Collect "garbage_collector"
            Collect "memory-heap"
            Collect "memory-nonheap"
            Collect "memory_pool"
            Collect "kafka.producer.request-rate"
        </Connection>
    </Plugin>
</Plugin>

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

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环境变量。像这样:

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

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

相关问题