通过kafka-configs.sh获得经纪人配置



我设置了AWS MSK,但是它没有GUI来查看服务器配置。我尝试使用kafka-configs.sh,但没有输出任何有用的东西。

./kafka-configs.sh --bootstrap-server {HOST} --entity-default --entity-type brokers --entity-name 1 --describe

输出: Configs for broker 1 are:

我尝试在当地的Kafka上进行此操作,并获得相同的价值。这是什么意思?

是的,这是一种已知行为:https://issues.apache.org/jira/browse/kafka-7720

当前此工具仅显示已动态覆盖的配置。

要查看所有经纪人配置,您有2个选项:

  • 使用AdminClient.describeConfigs() API
  • 调整configCommand.scala工具。

更新:此问题正在由KIP-524解决,该问题目前针对Kafka 2.5

最新更新