【发布时间】：2020-12-12 11:43:21
【问题描述】：
如何在 s3 连接器中使用 kafka msg 键作为分区标准或 如何获取密钥并将其也存储在 s3 对象中 谢谢！
【问题讨论】：
-
您需要阅读文档。您需要创建一个自定义分区器，这里是一个示例：stackoverflow.com/questions/62812932/…
标签： apache-kafka apache-kafka-connect
【发布时间】：2020-12-12 11:43:21
【问题描述】：
您可以使用 Transform 将键“移动”到值，然后将两者放在同一个对象中，然后传递给分区器。
https://github.com/jcustenborder/kafka-connect-transform-archive
【讨论】：