Узнать версию Kafka удаленно

Question

Есть ли способ узнать версию Kafka вне кластера?(возможно, с помощью telnet или другого инструмента)

только для пояснения, у меня нет ssh ни для Кафки, ни для зоопарка.

Answer 1

Самое простое решение для получения версии Kafka Cluster - это использование метрик JMX, предоставляемых каждым брокером.Как правило, JMX активируется на брокерах для целей мониторинга.

Версия может быть предоставлена ​​брокером через имя метрики:

kafka.server:type=app-info,version=<([-.\w]+)>

Для этого вы можете использовать jconsole или JmxTool , доступный в дистрибутиве Apache / Confluent Kafka.

Вот пример:

$> ./bin/kafka-run-class kafka.tools.JmxTool --jmx-url service:jmx:rmi:///jndi/rmi://:9999/jmxrmi --object-name kafka.server:type=app-info --attributes version 

Это дастВаш вывод:

Trying to connect to JMX url: service:jmx:rmi:///jndi/rmi://:9999/jmxrmi.
"time","kafka.server:type=app-info:version"
1556186760721,2.1.0-cp1
1556186762728,2.1.0-cp1
1556186764727,2.1.0-cp1

Обратите внимание, что вы должны сконфигурировать свойство --jmx-url с вашей собственной информацией о среде.

Answer 2

Можете ли вы подключиться к серверу с вашего компьютера через telnet, ssh ....?Если вы можете, вы можете проверить журналы kafka на удаленном сервере.

Например, я работаю на сервере linux Centos, kafka-logs находятся в / var / logs / kafka, тогда я могу сделать:

$ head -n 50  /var/log/kafka/kafka-broker-quickstart.cloudera.log 

проверьте вывод и найдите что-то вроде этого kafka-clients-2.1.0