2017-06-15 171 views
1

我陷入转储问题。它似乎至少是这样。生产者/消费者JMX指标

我想从kafka控制台生产者现在生成JMX度量标准。我完成了经纪人。

我有一个collectd CONF文件

``` LoadPlugin的java 的ObjectName “kafka.producer:类型=生产者 - 度量的clientId =([ - \瓦特] +)” InstancePrefix “所有” InstancePrefix“卡夫卡生产者请求率” 类型“计” 表假 属性“请求率”

<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> 

```

这对我来说很好,但是,collectd最终我得到collectd[552]: GenericJMXConfMBean: No MBean matched the ObjectName kafka.producer:type=producer-metrics,clientId=([-.w]+)

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

回答

0

您必须启用JMX设置JMX_PORT环境变量调用kafka_console_producer.sh面前:如何配置JMX

更多信息。例如:

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

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

0

正如我所说这是转储问题。 collectD不理解([ - 。\ w] +),我用*和clientId替换为client-id(我的不好)。

谢谢全部