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

谢谢!

simplehzj 回答:Apache-Pulsar吞吐量

可以存在多个消费者,只要该消费者没有限制即可。 消费者可以从生产者那里获取所需的证书文件,消费者可以命名订阅名称。并可以检查实际连接了哪些使用者。

本文链接:https://www.f2er.com/2900269.html

大家都在问