Как проверить состояние сервера Kafka или детали?

Question

Существует ли команда для отображения сведений о сервере Kafka или о состоянии сервера Kafka? (я не пытаюсь выяснить, запущен ли сервер kafka.)

Я могу найти информацию только по командам CLI для темы, раздела, производителя и потребителя.

Answer 1

Если вы ищете статус брокера Kafka, вы можете использовать zookeeper cli, чтобы найти подробную информацию о каждом брокере, как показано ниже:

ls /brokers/ids возвращает список идентификаторов активных брокеров в кластере.

get /brokers/ids/<id> возвращает сведения о брокере с указанным идентификатором.

Пример:

kafka_2.12-1.1.1 % ./bin/zookeeper-shell.sh localhost:2181 ls /brokers/ids
Connecting to localhost:2181

WATCHER::

WatchedEvent state:SyncConnected type:None path:null
[0]

kafka_2.12-1.1.1 % ./bin/zookeeper-shell.sh localhost:2181 get /brokers/ids/0
Connecting to localhost:2181

WATCHER::

WatchedEvent state:SyncConnected type:None path:null
{"listener_security_protocol_map":{"PLAINTEXT":"PLAINTEXT"},"endpoints":["PLAINTEXT://localhost:9092"],"jmx_port":-1,"host":"localhost","timestamp":"1558428038778","port":9092,"version":4}
cZxid = 0x116
ctime = Tue May 21 08:40:38 UTC 2019
mZxid = 0x116
mtime = Tue May 21 08:40:38 UTC 2019
pZxid = 0x116
cversion = 0
dataVersion = 0
aclVersion = 0
ephemeralOwner = 0x16ad9830f16000b
dataLength = 188
numChildren = 0

Вы можете поместить эти шаги в некоторый скрипт оболочки, чтобы получить подробностидля всех брокеров.

Answer 2

Вы можете активировать метрики JMX, установив переменную среды JMX_PORT.

$ export JMX_PORT=9010
$ ./bin/kafka-server-start.sh ./config/server.properties

Затем вы можете использовать jconsole или Java Mission Control для отображения метрик кластера.