Spring Kafka：C ++生产者对ReplyingKafkaTemplate的答复

如何解决Spring Kafka：C ++生产者对ReplyingKafkaTemplate的答复

我使用ReplyingKafkaTemplate向Kafka发送请求并收到回复。 请求的使用者是C ++程序。处理完请求后，C ++应用程序将产生答复。现在我的问题是关于回复的格式，因为春季的回复用户似乎使用相关ID查找相应的回复。 有人可以帮我解决这个问题吗？

解决方法

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