请问:Shared/Key_Shared模式下,如何让订阅端均衡消费?

场景1 pulsar2.9.2+camel
三台服务器独立部署的camel应用;采用Shared模式,使用相同的SubscriptionName,订阅同一个Topic;Topic partition为3。
也是想通过Shared模式均衡消费,但实际情况是:基本只命中了其中一台,另外两台完全闲置,没有消费Topic消息。

场景2 flink1.14.4+pulsar2.9.2+pulsar-connector1.14.4
三台服务器独立部署的flink应用,每一台都单独运行job;每一台的flink应用,均采用Shared订阅topic,使用同一个SubscriptionName;Source的并行度设置为1;Topic partition为3。
本想通过Shared可以使三台flink应用能均衡消费Topic,但实际的情况是:基本上只命中了其中两台,另外一台flink应用完全闲置,没有消费Topic消息。

所以,想请教下:Shared/Key_Shared模式下,如何让消费的均衡订阅?

理论上,shared模式可以实现均衡消费(轮询方式)。
如果测试出来结果是不均衡,建议把测试环境及问题log等整理发出来。

非常感谢,目前调整了设置,暂时采用的shared模式,看到几个消费点都有数据进来了。

2 Likes