@SentTo 如何将消息发送到相关主题？

Question

我在我的 Rest 控制器中使用 ReplyingKafkaTemplate 来返回同步响应。我也在设置标题 REPLY_TOPIC。对于监听器微服务部分，

 @KafkaListener(topics = "${kafka.topic.request-topic}")
 @SendTo
 public Model listen(Model<SumModel,SumResp> request) throws InterruptedException {

   SumModel model = request.getRequest();
   int sum = model.getNumber1() + model.getNumber2();

   SumResp resp = new SumResp(sum);
   request.setReply(resp);

   request.setAdditionalProperty("sum", sum);
   return request;
 }

我的问题是，@sentTo 注释如何管理将消息发布到标题中提供的主题。应该有一个KafkaTemplate bean还是不需要它？因为我们只是在不使用任何 KafkaTemplate 或 ReplyingKafkaTemplate bean 的情况下返回消息。

如果没有任何 kafka 模板，它可以工作还是需要 KafkaTemplate 或 ReplyingKafkaTemplate bean？

谢谢

Answer 1

是的，使用模板发送回复...

Assert.state(replyTopic == null || this.replyTemplate != null,
        "a KafkaTemplate is required to support replies");

如果应用程序上下文中恰好有一个模板，则 Spring Boot 会自动将模板连接到侦听器容器工厂。

map.from(this.replyTemplate).to(factory::setReplyTemplate);

如果上下文中还没有模板，Boot 还会自动配置模板。