apt install ./apache-pulsar-client*.deb

const client = new Pulsar.Client({
  serviceUrl:
    '<http://pulsar-47aqq2352p5e.tdmq-pulsar.ap-sh.qcloud.tencenttdmq.com:5039>', //更换为接入地址（控制台集群管理页完整复制）
  authentication: new Pulsar.AuthenticationToken({
    token:
      'token', //更换为密钥
  }),
});

// 消费者
const consumer = await client.subscribe({
  topic: 'pulsar-47aqq2352p5e/npm/list',
  subscription: 'my-subscription',
  subscriptionType: 'Exclusive',
  listener: (msg, msgConsumer) => {
    console.log('-------------------------------');
    console.log(msg.getData().toString());
    console.log('-------------------------------');
    msgConsumer.acknowledge(msg);
  },
});

// 生产者
const producer = await buildProducer('pulsar-47aqq2352p5e/npm/list');

const res = await producer.send({
  data: Buffer.from('Hello, Pulsar'),
});