查看 Google Cloud Managed Service for Apache Kafka 集群中的代理

Managed Service for Apache Kafka 会自动为集群预配代理。代理具有以下属性:

  • brokerIndex:代理的索引(从零开始)。
  • nodeId:代理的节点 ID。
  • rack:预配代理的可用区,例如 us-central1-a

如需查看集群的代理,请执行以下步骤。

控制台

  1. 前往 Managed Service for Apache Kafka > 集群 页面。

    转到“集群”

  2. 点击集群的名称。

  3. 选择配置 标签页。集群的代理列在活跃代理 下方。

gcloud

如需获取集群的代理列表,请使用 managed-kafka clusters describe 命令和 --full 标志。

gcloud managed-kafka clusters describe CLUSTER_ID \
  --location=LOCATION \
  --full \
  --format="yaml(brokerDetails)"

替换以下内容:

  • CLUSTER_ID:集群的 ID 或名称。
  • LOCATION:集群的位置。

输出类似于以下内容:

brokerDetails:
- brokerIndex: '0'
  nodeId: '10'
  rack: us-central1-c
- brokerIndex: '1'
  nodeId: '11'
  rack: us-central1-f
- brokerIndex: '2'
  nodeId: '12'
  rack: us-central1-b

Kafka CLI

在运行此命令之前,请在 Compute Engine 虚拟机上安装 Kafka 命令行工具。虚拟机必须能够访问连接到 Managed Service for Apache Kafka 集群的子网。请按照 使用 Kafka 命令行工具生成和使用消息中的说明操作。

如需获取集群的代理列表,请使用带有 --entity-type=brokers 标志的 kafka-configs.sh --describe 命令。

kafka-configs.sh --describe --entity-type brokers \
  --bootstrap-server=BOOTSTRAP_ADDRESS \
  --command-config client.properties

BOOTSTRAP_ADDRESS 替换为集群的 启动地址

此命令会返回代理 ID 列表,以及代理的动态配置设置(如果有)。它不会返回 rack 属性。

后续步骤