Kafka多消费回复场景：两类ReplyingKafkaTemplate选型咨询

原因分析 #

• ReplyingKafkaTemplate的局限：它仅适配单请求单响应的场景，发送一条消息后只会等待并接收一个匹配CorrelationId的回复。你这里用同一个CorrelationId发送了两条消息，会产生两个回复，ReplyingKafkaTemplate无法处理这种多回复情况，要么只拿到第一个回复就结束流程，要么后续回复会引发异常。
• AggregatingReplyingKafkaTemplate的适配性：这个模板专门为「一个请求对应多个响应」的场景设计。你可以配置它等待指定数量的回复（这里是2个），或者设置超时时间，它会自动收集所有匹配同一CorrelationId的回复并聚合返回，完全契合你的需求——用同一CorrelationId发送两条消息，接收两个消费者的回复并汇总。

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