使用kafka密钥的kafka s3连接器分区

Question

如何使用 kafka 消息密钥作为 s3 连接器中的分区标准或 如何获取密钥并将其存储在 s3 对象中 谢谢！

Answer 1

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

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