如何在Kraft模式的Kafka 3.3集群中通过命令行查找控制器ID

优先命令行方式（推荐） #

Kafka 3.3的KRaft模式下，kafka-metadata-shell.sh是查询元数据的专用工具，可直接获取控制器信息：

• 执行元数据shell连接命令，替换<bootstrap地址>为你的Kafka集群bootstrap地址（例如localhost:9092）：

  kafka-metadata-shell.sh --bootstrap-server <bootstrap地址>
  

• 进入交互shell后，输入命令查询控制器详情：

  get /controller
  

  返回结果示例：

  {"version":1,"brokerid":1,"timestamp":"1699999999999"}
  结果中的brokerid字段即为当前集群的控制器ID。

备选方式（日志查询） #

若命令行工具无法使用，可查看Kafka节点的日志文件（默认路径为logs/server.log），搜索关键字Controller is ready to serve requests，日志行中会明确标注控制器ID：

[2023-11-13 10:00:00,000] INFO [Controller id=1] Controller is ready to serve requests (kafka.controller.Controller)

内容的提问来源于stack exchange，提问作者Dojo