Using Pulsar as a message queue

对于消息队列而言,Pulsar 是绝佳选择,这是因为:

  • 消费者提供主题消息的自动负载均衡(支持自定义负载均衡)。

客户端配置更改

  • 建立共享订阅,使用与其他消费者相同的订阅名称(否则订阅将不共享,消费者集群无法充当处理集合)

以下是使用共享订阅的 Java 消费者配置示例:

以下是使用共享订阅的 Python 消费者配置示例:

Here is an example of a Go consumer configuration that uses a shared subscription: