我正在尝试实现一种回复模式,在这种模式中,我发布一条消息,指向几个消费者群体所收听的主题。这意味着他们都将在回复主题中获得消息并提交响应。
问题是因为它们都响应同一条消息,所以只有回复主题中的第一条收到的消息才会被回复。其他的将被丢弃。既然我知道在回复主题上应该得到多少个回复(称为n),那么如何让回复kafkatemplate等待n个回复,然后解析答案呢?我试着从斯普林Kafka的文档中推断出来,但不太明白。谢谢。
我正在尝试实现一种回复模式,在这种模式中,我发布一条消息,指向几个消费者群体所收听的主题。这意味着他们都将在回复主题中获得消息并提交响应。
问题是因为它们都响应同一条消息,所以只有回复主题中的第一条收到的消息才会被回复。其他的将被丢弃。既然我知道在回复主题上应该得到多少个回复(称为n),那么如何让回复kafkatemplate等待n个回复,然后解析答案呢?我试着从斯普林Kafka的文档中推断出来,但不太明白。谢谢。
1条答案
按热度按时间uurv41yg1#
该模板严格用于单个请求/回复处理。
你不能把它用于你的用例。
使用
KafkaTemplate
一个单独的倾听者;你必须自己把答复联系起来。