具有一个回复主题的异步请求回复模式

Question

当生产者向具有相同关联 ID 的不同消费者发送不同消息并在常见回复话题.

具体来说，生产者 P1 生成消息 M1 并使用主题 T1 将其发送给使用 CorrelationId ="123" 的消费者 C1。此外，生产者 P1 生成消息 M2 并使用主题 T2 使用 correlationId =“123”将其发送给消费者 C2

两个消费者（C1 和 C2）都使用对同一回复主题 R1 的回复进行回复。

在这种情况下，我们应该使用ReplyingKafkaTemplate还是AggregatingReplyingKafkaTemplate？

Answer 1

AggregatingReplyingKafkaTemplate 不支持这种情况；它用于向多个消费者发送相同的消息并汇总他们的回复。

对于您的用例，您需要使用离散的 ReplyingKafkaTemplate 调用并自行执行聚合。

如果您使用相同的回复主题，您应该将 sharedReplyTopic 设置为 true 以避免日志噪音。

回复容器必须有不同的group.ids。