Spring Kafka:ReplyingKafkaTemplate 回复的 C++ 生产者

Spring Kafka: C++ producer of reply for ReplyingKafkaTemplate

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

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