配置 ReplyingKafkaTemplate 以获取来自多个主题的响应

Configuring ReplyingKafkaTemplate for getting the responses from multiple topics

我有一个要求,我必须在 Kafka 中使用同步请求-回复模式,因此我正在使用 ReplyingKafkaTemplate

作为实现的一部分,有一个生产者正在推送关于一个主题的请求消息(input-message-topic1)但是在return我是期待来自两个主题(output-message-topic1output-message-topic2)的回复,我必须进一步汇总和处理。

问题:是否可以使用 ReplyingKafkaTemplate / A​​ggregatingReplyingKafkaTemplate 或任何其他使用同步请求-回复模式的实现来实现上述场景与卡夫卡?

是的,AggregatingReplyingKafkaTemplate 会这样做;只需将其侦听器容器配置为从两个主题中消费;回复必须包含相关 ID header(用于聚合)。