2017-06-15 170 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(我的不好)。

謝謝全部