使用 ReplyingKafkaTemplate 处理多个响应

Question

我正在尝试实现一种回复响应模式，在该模式中，我向多个消费者群体收听的主题发布一条消息。这意味着他们都将收到消息并在回复主题中提交回复。

问题是因为他们都回复了同一条消息，所以只回复回复主题中第一个收到的消息。其他的将被丢弃。 鉴于我知道我应该在回复主题上获得多少回复（称之为数字-n），我怎样才能让 ReplyingKafkaTemplate 等待 n 回复然后解决答案？ 我试过从 Spring Kafka documentation 推断，但不太明白。 谢谢

Answer 1

该模板仅用于单个 request/reply 处理。

您不能将它用于您的用例。

使用一个KafkaTemplate和一个单独的监听器；您必须自己关联回复。