Métrique JMX producteur/consommateur

Question

Je me suis retrouvé dans un problème de vidage. il semble au moins comme ça. J'essaie de générer des métriques JMX à partir du producteur de la console kafka dès maintenant. J'ai fini avec le courtier.

J'ai un fichier de configuration de collectd

`` ` LoadPlugin java ObjectName "kafka.producer: type = producteurs-métriques, clientId = ([- \ w.] +)" InstancePrefix "all" InstancePrefix "kafka-producteur demande taux" type "jauge" Tableau faux Attributs "demande taux"

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

`` `

cela semble bon pour moi, mais à la fin collectd je reçois collectd[552]: GenericJMXConfMBean: No MBean matched the ObjectName kafka.producer:type=producer-metrics,clientId=([-.w]+)

toute aide est appréciée. Thanks-Tarun

Answer 1

Voyez-vous que jmx est activé lorsque vous exécutez jps -v?

-Dcom.sun.management.jmxremote.port=9999 doit être visible dans votre cas.

Plus d'informations sur la façon de configurer JMX: http://docs.confluent.io/current/cp-docker-images/docs/operations/monitoring.html

Answer 2

Vous devez activer la variable d'environnement JMX_PORT mise JMX avant d'appeler kafka_console_producer.sh. Quelque chose comme ceci:

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

Voir bin/script kafka-run-class.sh pour plus de détails.

Answer 3

Comme je l'ai dit c'est un problème de vidage. collectD ne comprend pas ([-. \ w] +), j'ai remplacé cela par * et clientId par client-id (mon mauvais). Merci à tous