租户端 互联网中间件 消息队列（TDMQ） SDK文档

Node.js SDK

最近更新时间: 2025-10-11 18:10:00

操作场景

TDMQ Pulsar 版2.7.1及以上版本的集群已支持 Pulsar 社区版 Node.js SDK。本文介绍如何使用 Pulsar 社区版 Node.js SDK 完成接入。

前提条件

  • 获取接点地址 在 TDMQ 控制台【集群管理】页面复制接入地址。
  • 获取密钥 已参考 【角色与鉴权】 文档配置好了角色与权限，并获取到了对应角色的密钥（Token）。

操作步骤

  1. 按照 Pulsar 官方文档在您客户端所在的环境中安装 Node.js Client。

    $ npm install pulsar-client

  2. 在创建 Node.js Client 的代码中，配置准备好的接入地址和密钥。

const Pulsar = require("pulsar-client");

(async () => {
  const client = new Pulsar.Client({
    serviceUrl: "http://*",   //更换为接入地址（控制台集群管理页完整复制）
    authentication: new Pulsar.AuthenticationToken({
      token: "eyJh**",       //更换为密钥
    }),
  });
  await client.close();
})();

关于 Pulsar 社区版 Node.js SDK 各种功能的使用方式，请参考Pulsar 官方文档。