如何确保特定消息发送至Pulsar指定消费者？

要实现特定消息精准发送给指定消费者，key-shared模式确实无法满足需求——它仅能基于消息key的哈希范围做分组分配，无法指定具体消费者。以下是几种可行的解决方案：

方案1：主题分区+指定分区订阅 #

这是最可靠的精准路由方式：

• 给目标主题创建多个物理分区，每个需要指定接收的消费者仅订阅固定的某个分区。
• 发送消息时，将指定给某消费者的消息直接发送到其对应的分区。
• 操作示例：
  • 创建分区主题：bin/pulsar-admin topics create-partitioned-topic persistent://public/default/my-topic -p 3
  • 消费者指定订阅分区（Java客户端示例）：consumerBuilder.assignedPartition(Partition.of("my-topic", 0))
  • 生产者指定发送分区（Java客户端示例）：producerBuilder.messageRouter(new SinglePartitionMessageRouter(0))

方案2：自定义标识+消费者过滤 #

如果不想依赖分区，可通过消息属性配合过滤器实现：

• 发送消息时，为消息添加自定义属性（比如目标消费者ID）：messageBuilder.addProperty("target_consumer", "consumer_001")
• 消费者订阅时设置过滤规则，仅接收带有自身标识的消息：consumerBuilder.filter("target_consumer = 'consumer_001'")
• 注意：这种方式会让Broker先接收所有消息再做过滤，消息量较大时会增加Broker负载，适合小规模场景。

方案3：专用主题（最直接） #

给每个需要单独接收消息的消费者创建专属主题，直接将特定消息发送到对应主题。这种方式逻辑最简单，无需复杂配置，但会增加主题数量，需要做好主题生命周期管理。

补充：key-shared模式的局限性 #

key-shared的核心是保证相同key的消息被同一消费者处理，其哈希分组由Broker自动维护，消费者上下线时哈希范围会重新分配，因此无法实现精准指定某一个消费者接收消息。

内容的提问来源于stack exchange，提问作者Kevin Z.