Spring Kafka:ReplyingKafkaTemplate 回复的 C++ 生产者
Spring Kafka: C++ producer of reply for ReplyingKafkaTemplate
我使用 ReplyingKafkaTemplate 向 Kafka 发送请求并接收回复。
请求的消费者是 C++ 程序。处理请求后,其回复由 C++ 应用程序生成。现在我的问题是关于回复的格式,因为 spring 端回复的消费者似乎使用相关 ID 来找到相应的回复。
有人可以帮我解决这个问题吗?
您需要回显 correlationId header 以便模板知道此回复针对的是哪个请求。只需将 C++ 代码中回复的 header 设置为传入请求的值 header.
我使用 ReplyingKafkaTemplate 向 Kafka 发送请求并接收回复。 请求的消费者是 C++ 程序。处理请求后,其回复由 C++ 应用程序生成。现在我的问题是关于回复的格式,因为 spring 端回复的消费者似乎使用相关 ID 来找到相应的回复。 有人可以帮我解决这个问题吗?
您需要回显 correlationId header 以便模板知道此回复针对的是哪个请求。只需将 C++ 代码中回复的 header 设置为传入请求的值 header.