0

我使用 ReplyingKafkaTemplate 向 Kafka 发送请求并接收回复。请求的消费者是一个 C++ 程序。处理请求后,其回复由 C++ 应用程序生成。现在我的问题是关于回复的格式,因为spring-side中回复的消费者似乎使用相关ID来找到相应的回复。有人可以帮我解决这个问题吗?

4

1 回答 1

0

您需要回显correlationId 标头,以便模板知道该回复是针对哪个请求的。只需将 C++ 代码中回复的标头设置为传入请求标头的值。

于 2020-11-09T19:45:02.003 回答