2017-06-15 1 views
1

ダンプの問題が発生しました。それは少なくともそれのように思える。プロデューサ/コンシューマJMXメトリック

私は現在、kafkaコンソールプロデューサーからJMXメトリックを生成しようとしています。私はブローカーとやっている。

Iはcollectd confファイルを

` LoadPluginジャワ ObjectNameを持っている "kafka.producer:([ - \ W] +)タイプ=プロデューサメトリックの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

あなたはkafka_console_producer.shを呼び出す前にJMX_PORT環境変数を設定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(私の悪い)に置き換えました。

ありがとうございました

関連する問題