Using Pulsar as a message queue

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

• 构建之初就考虑到了。

客户端配置更改

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

• If you’d like to have tight control over message dispatching across consumers, set the consumers’ receiver queue size very low (potentially even to 0 if necessary). 每个 Pulsar 消费者都有一个接收器队列，用于确定消费者一次尝试获取的消息数量。 例如，接收器队列 1000 （默认值）意味着消费者将尝试在连接时处理来自主题的 1000 条待办消息。 将接收器队列值设置为零实质上意味着确保每个消费者一次只做一件事。

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

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