Using Pulsar as a message queue
对于消息队列而言,Pulsar 是绝佳选择,这是因为:
- 为消费者提供主题消息的自动负载均衡(支持自定义负载均衡)。
客户端配置更改
建立共享订阅,使用与其他消费者相同的订阅名称(否则订阅将不共享,消费者集群无法充当处理集合)
以下是使用共享订阅的 Java 消费者配置示例:
以下是使用共享订阅的 Python 消费者配置示例:
Here is an example of a Go consumer configuration that uses a shared subscription: