Activer JMX sur Kafka Courtiers
J'ai activé JMX sur Kafka courtiers en ajoutant
`KAFKA_JMX_OPTS="-Dcom.sun.management.jmxremote=true
-Dcom.sun.management.jmxremote.authenticate=false
-Dcom.sun.management.jmxremote.ssl=false
-Djava.rmi.server.hostname=<server_IP>
-Djava.net.preferIPv4Stack=true`“.
Cependant, lorsque j'utilise " kafka.outils.JmxTool’ pour obtenir les paramètres, il affiche le temps Unix timbres qui ne sont pas le comportement attendu.
sh /usr/local/kafka/bin/kafka-run-class.sh kafka.tools.JmxTool -- object-name 'kafka.server:type=BrokerTopicMetrics,name=AllTopicsMessagesInPerSec' --jmx-url service:jmx:rmi:///jndi/rmi://<server_IP>:9111/jmxrmi
La commande ci-dessus affiche le temps Unix timbres. Comment puis-je corriger ce problème et il imprime les statistiques?
OriginalL'auteur sui | 2016-04-19
Vous devez vous connecter pour publier un commentaire.
Modifier bin/kafka-run-class.sh et ensemble KAFKA_JMX_OPTS variable
Mise à jour bin/kafka-server-start.sh ajouter la ligne ci-dessous
export JMX_PORT=PORT
avant le début de Kafka service est suffisant pour permettre la JMX sur mon mac. J'ai testé avec jconsole. Et si vous souhaitez connecter le producteur et le consommateur, de définir ou d'exporter différents jmx port avant le début de chaque.est-il nécessaire de redémarrer kafka ?
yeap 🙂
OriginalL'auteur chandramohan
Vous devez définir 'JMX_PORT variable, ou ajouter la ligne suivante bin/kafka-server-start.sh.
alors vous serez en mesure de se connecter à Kafka JMX métriques. J'ai utiliser l'outil jconsole et 'localhost:9999' adresse.
OriginalL'auteur MeetJoeBlack
puis ajouter les deux premières lignes et le commentaire que j'ai fait pour les autres lignes, (Note : après avoir fait cette Kafka scripts ne peuvent pas être utilisés pour les opérations de client pour l'inscription de sujets.. pour vos activités du client, vous devez utiliser l'un des scripts séparés , téléchargez-le à nouveau dans des endroits différents et à l'utilisation)
OriginalL'auteur supermonk
Réglage
JMX_PORT
à l'intérieur debin/kafka-run-class.sh
en découdront avec Zookeeper, si vous exécutez Zookeeper sur le même nœud.Le mieux est de mettre
JMX
port individuellement à l'intérieur correspondantserver-start
scripts:“export JMX_PORT=${JMX_PORT:-9998}”
avant dernière ligne$KAFKA_HOME/bin/zookeeper-server-start.sh
fichier.“export JMX_PORT=${JMX_PORT:-9999}”
avant dernière ligne$KAFKA_HOME/bin/kafka-server-start.sh
fichier.Cette réponse est parfaitement fonctionné pour mon problème. Je suis en utilisant kafka_2.11-2.0.0 & zookeeper-3.4.12 ensemble 3 nœud de cluster. Cette solution a fonctionné pour Kafka-Manager JMX des indicateurs de l'affichage des graphiques ainsi que des kafka-topics.sh --liste --zookeeper & Kafka Console Producteur (kafka-console-producer.sh --courtier-liste ) & Console Consommateur (kafka-console-consumer.sh --bootstrap-serveur) & kafka-topics.sh --décrire. La gardienne & Kafka tous les deux travaillent sur différents ports JMX. Zookeeper de travail sur le port 9998 et Kafka & Kafka-Manager de travail sur le port 9999. Merci @Rahul Singhai
OriginalL'auteur Rahul Singhai
Utilisation
kafka.server:type=BrokerTopicMetrics,name=MessagesInPerSec
La
AllTopics
préfixe est utilisé dans les verions. Vous pouvez spécifier le sujet à l'aide dekafka.server:type=BrokerTopicMetrics,name=MessagesInPerSec,topic=<topic-name>
src: http://grokbase.com/t/kafka/users/164ksnhff0/enable-jmx-on-kafka-brokers
OriginalL'auteur AndyTheEntity
Si vous êtes en cours d'exécution via systemd:
systemctl daemon-reload
systemctl restart kafka
echo 'beans' | java -jar jmxterm-1.0-alpha-4-uber.jar -l localhost:9989 -n 2>&1
OriginalL'auteur ethrbunny