如何在 Kafka Connect S3 中解析记录 headers？
How to parse record headers in Kafka Connect S3?
我使用 Kafka Connect S3 Sink，它只将记录的值写入 S3。我想将一些记录的 headers 合并到写入 S3 的最终负载中。
我该怎么做？
您需要使用简单消息转换来拦截记录并解压缩 headers 并将它们“移动”到记录 object.
的值部分
在Kafka Connect S3的源码中，可以看到确实只写了记录值
我使用 Kafka Connect S3 Sink，它只将记录的值写入 S3。我想将一些记录的 headers 合并到写入 S3 的最终负载中。
我该怎么做？
您需要使用简单消息转换来拦截记录并解压缩 headers 并将它们“移动”到记录 object.
的值部分在Kafka Connect S3的源码中，可以看到确实只写了记录值