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

标签 apache-kafka

是否有命令可以显示 Kafka 服务器的详细信息或 Kafka 服务器的状态? (我不是想知道 kafka 服务器是否正在运行。)

我只能找到关于主题、分区、生产者和消费者 CLI 命令的信息。

最佳答案

如果您正在寻找 Kafka 集群代理状态,您可以使用 zookeeper cli 查找每个代理的详细信息,如下所示:
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 脚本中以获取所有代理的详细信息。

关于apache-kafka - 如何查看Kafka服务器状态或详细信息?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/56234346/

相关文章:

java - @KafkaClient的id属性有什么用

spring-integration - 通过拒绝确认重读来自 Kafka 主题的消息

java - Spring和卡夫卡: Join 3 Kafka topics to generate output Kafka streams

apache-kafka - Camel-Kafka 安全协议(protocol) SASL_SASL 不起作用

apache-kafka - 如何向 kafka 消费者传达 Kafka 生产者已完成的信息?

rabbitmq - 在微服务的发布/订阅模型中,如何只接收/使用每种服务类型的消息一次

apache-kafka - 卡夫卡有批量消费者吗?

apache-kafka - KSQLDB Emit Final 不返回任何值

scala - 如何在运行测试之前启动 docker 容器

apache-kafka - Zookeeper 在与 kafka 相同的节点上?