使用kafka键的kafka s3连接器分区

问题描述

我怎样才能将kafka msg键用作s3连接器中的分区标准，或者 我如何获取密钥并将其也存储在s3对象中 谢谢！

解决方法

您可以使用Transform将键“移动”到值，然后将两者都放在同一个对象中，然后再传递给分区程序。

https://github.com/jcustenborder/kafka-connect-transform-archive