node.js - Apache-Pulsar 吞吐量

我在本地机器上独立运行 apache-pulsar 作为 docker 容器，用于排队系统并将 1000 个作业推送到一个主题（比如说“演示”）。

如果我有 1 个消费者正在收听“演示”主题并处理工作并确认（在 100 毫秒 - 500 毫秒内）。所有工作在大约 80 秒内完成。

但是，如果我对更多消费者（2 或 4 个消费者）进行相同的 1000 个作业测试，则总体吞吐量保持不变，大约为 80 秒。

我不确定我是否缺少一些需要的配置或是否需要多个脉冲星代理，或者我应该怎么做，如果我增加消费者，消费吞吐量也应该增加（如果有 2 个消费者，大约需要 40-45 秒）。

Docker 镜像：apachepulsar/pulsar

消费者选项：“subscriptionType”：“Shared”，“receiverQueueSize”：100，“ackTimeoutMillis”：1200000

谢谢！

标签： node.jsthroughputapache-pulsar

您确定您实际上正在运行多个消费者吗？它们在多个容器中吗？虚拟机？服务器？每人收到多少？

他们是在使用异步还是同步？

什么版本的 NodeJS？什么版本的客户端？什么版本的脉冲星？

尝试将队列大小增加到 1000

要在一个地点接触所有 Pulsar 人，请注册参加峰会。