跳到主要内容

AdminClient

2025年02月23日
柏拉文
越努力，越幸运

一、创建 AdminClient​

const Kafka = require("node-rdkafka");

const adminClient = Kafka.AdminClient.create({
  "client.id": "kafka-admin",
  "metadata.broker.list": "localhost:29092",
});

console.log("adminClient", adminClient);

  • client.id: 这是客户端的标识符，用于标识当前这个 AdminClient 的身份。在 Kafka 集群中，客户端通常会使用 client.id 来做日志记录和监控，这有助于追踪请求来源，便于调试和性能分析。

  • metadata.broker.list: 指定 Kafka 集群中 Broker 的地址列表。这个参数告诉 AdminClient 连接哪个 Broker 来获取元数据信息（如 Topic、分区、副本等信息）。