如何在s3连接器中使用kafka msg key作为分区标准，或者如何获取密钥并将其存储在s3对象中，谢谢！
ff29svar1#
您可以使用转换将键“移动”到值，然后将两者都放在同一个对象中，然后传递给分区器。https://github.com/jcustenborder/kafka-connect-transform-archive
1条答案
按热度按时间ff29svar1#
您可以使用转换将键“移动”到值，然后将两者都放在同一个对象中，然后传递给分区器。
https://github.com/jcustenborder/kafka-connect-transform-archive