c++ - Spring Kafka：ReplyingKafkaTemplate 回复的 C++ 生产者

Question

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

Answer 1

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