我正在本地计算机上独立运行apache-pulsar作为docker容器来排队系统,并将1000个作业推到一个主题(让我们说“演示”)。
如果我有1位消费者在听“演示”主题并处理作业并确认(100毫秒至500毫秒内)。所有工作都在大约80秒内完成。
但是,如果我在更多的使用者(2个或4个使用者)中进行了相同的1000个工作测试,则总体吞吐量保持不变,大约为80秒。
我不确定我是否缺少某些配置,或者是否需要多个脉冲星经纪人,或者我应该怎么做,以便如果增加消费者,消费吞吐量也应该增加(例如,如果有2个消费者,则大约40-45秒) )。
Docker映像:apachepulsar / pulsar
消费者选项: “ subscriptionType”:“ Shared”, “ receiverQueueSize”:100, “ ackTimeoutMillis”:1200000
谢谢!