¿Cómo puedo usar la clave kafka msg como criterio de partición en el conector s3 O cómo puedo obtener la clave y almacenarla también en el objeto s3? ¡Gracias!

0
ALjazzguitar 23 ago. 2020 a las 21:42

1 respuesta

La mejor respuesta

Puede usar una Transformación para "mover" la clave al valor, luego tener ambos en el mismo objeto que luego se pasa al particionador.

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

1
OneCricketeer 24 ago. 2020 a las 19:37