配置 ReplyingKafkaTemplate 以获取来自多个主题的响应
Configuring ReplyingKafkaTemplate for getting the responses from multiple topics
我有一个要求,我必须在 Kafka 中使用同步请求-回复模式,因此我正在使用 ReplyingKafkaTemplate。
作为实现的一部分,有一个生产者正在推送关于一个主题的请求消息(input-message-topic1)但是在return我是期待来自两个主题(output-message-topic1 和 output-message-topic2)的回复,我必须进一步汇总和处理。
问题:是否可以使用 ReplyingKafkaTemplate / AggregatingReplyingKafkaTemplate 或任何其他使用同步请求-回复模式的实现来实现上述场景与卡夫卡?
是的,AggregatingReplyingKafkaTemplate
会这样做;只需将其侦听器容器配置为从两个主题中消费;回复必须包含相关 ID header(用于聚合)。
我有一个要求,我必须在 Kafka 中使用同步请求-回复模式,因此我正在使用 ReplyingKafkaTemplate。
作为实现的一部分,有一个生产者正在推送关于一个主题的请求消息(input-message-topic1)但是在return我是期待来自两个主题(output-message-topic1 和 output-message-topic2)的回复,我必须进一步汇总和处理。
问题:是否可以使用 ReplyingKafkaTemplate / AggregatingReplyingKafkaTemplate 或任何其他使用同步请求-回复模式的实现来实现上述场景与卡夫卡?
是的,AggregatingReplyingKafkaTemplate
会这样做;只需将其侦听器容器配置为从两个主题中消费;回复必须包含相关 ID header(用于聚合)。