生产者/消费者 JMX 指标答案

【问题标题】：Producer/consumer JMX metrics生产者/消费者 JMX 指标
【发布时间】：2017-06-15 01:13:28
【问题描述】：

我陷入了转储问题。至少看起来是这样的……

我现在正在尝试从 kafka 控制台生产者生成 JMX 指标。我已经完成了经纪人。

我有一个收集的 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]+)

任何帮助表示赞赏。
谢谢-Tarun

【问题讨论】：

标签： apache-kafka jmx collectd

【解决方案1】：

当你运行 jps -v 时，你看到 jmx 启用了吗？

-Dcom.sun.management.jmxremote.port=9999 在您的情况下应该是可见的。

更多关于如何配置 jmx 的信息：http://docs.confluent.io/current/cp-docker-images/docs/operations/monitoring.html

【讨论】：

【解决方案2】：

您必须在调用 kafka_console_producer.sh 之前启用 JMX 设置 JMX_PORT 环境变量。像这样的：

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

详见 bin/kafka-run-class.sh 脚本。

【讨论】：

【解决方案3】：

正如我所说，这是转储问题。 collectD 不理解 ([-.\w]+)，我将其替换为 * 并将 clientId 替换为 client-id（我的错误）。

谢谢大家

【讨论】：