如何解析Kafka Connect S3中的记录头

Question

我使用Kafka Connect S3 Sink，它只将记录的值写入S3。我想将一些记录的头合并到写入S3的最终有效负载中。

我该怎么做？

Answer 1

您需要使用简单消息转换来拦截记录并解压缩标头；移动"；将它们添加到记录对象的值部分。

在Kafka Connect S3的源代码中，您可以看到记录值确实只是写的。