基于Pulsar的生产者专属消息处理反馈实现方案咨询

不需要为每个生产者单独创建输出主题，Pulsar完全适配你的业务场景，以下是两种可行的实现方案：

方案一：标识过滤或键控路由 #

• 带标识过滤：每个生产者发送消息时，在消息属性中加入自身唯一标识（比如自定义的生产者ID、客户端ID）。服务处理完消息后，将该标识原样写入反馈消息。生产者订阅输出主题时，通过ConsumerBuilder.messageFilter()设置过滤规则，只消费带有自身标识的消息。
• 键控消息+键共享订阅：生产者发送消息时指定messageKey为自身唯一标识，服务处理后的反馈消息沿用相同的messageKey。生产者采用键共享订阅模式订阅输出主题，Pulsar会自动将相同key的消息路由到对应的消费者（即原生产者），无需手动过滤，性能更优。

方案二：原生请求-响应模式 #

Pulsar原生支持请求-响应场景：生产者发送消息时通过replyTo参数指定一个临时主题（可使用TopicName.getRandomName()生成），服务处理完成后直接将结果发送到该临时主题，只有发起请求的生产者能收到反馈。临时主题会在生产者关闭后自动销毁，无需额外管理，适合一对一的即时反馈场景。

补充说明 #

• 消费端过滤实现简单，但消息量极大时，键共享订阅的方式性能更优，因为broker端已完成路由，减少消费者端的过滤开销。
• 原生请求-响应模式是最简洁的方案，无需额外的标识管理或过滤逻辑，适合单次请求对应单次反馈的场景。

内容的提问来源于stack exchange，提问作者TeaJ