如何查看Kafka服务器状态或详细信息?

ls /brokers/ids 返回群集上活动代理ID的列表。

get /brokers/ids/<id> 返回具有给定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

您可以将这些步骤放在一些shell脚本中,以获取所有代理的详细信息。

您可以通过设置环境变量来激活JMX度量 JMX_PORT .

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

然后,你可以使用 J控制台 或 显示群集度量。