我使用kafka connect s3 sink，它只将记录的值写入s3。我想将一些记录头合并到写入s3的最终有效负载中。我该怎么做？
uqxowvwt1#
您需要使用一个简单的消息转换来截获记录，解压头并将它们“移动”到record对象的value部分。在Kafka连接s3的源代码中，可以看到记录值确实是只写的。
1条答案
按热度按时间uqxowvwt1#
您需要使用一个简单的消息转换来截获记录，解压头并将它们“移动”到record对象的value部分。
在Kafka连接s3的源代码中，可以看到记录值确实是只写的。