我需要处理kafka-stream中的request记录，还需要告诉发送者处理的response。我创建了一个 Rest 端点来接收请求。该端点使用 spring-kafka 的 ReplyingKafkaTemplate，它发送一个主题的请求并等待另一个主题的响应。相关 id 标头用于关联请求和响应。
如何在处理 request 记录后发送的 kafka-stream 代码中的 response 记录中设置相关 id 标头？
添加流处理器以将输入标头复制到输出记录。
https://docs.confluence.io/platform/current/streams/developer-guide/processor-api.html