Acceso de clave Kafka en el ingreso de una función Python Flink con estado.
He estado mirando las funciones con estado de Flink. Parece muy prometedor, excepto por una cosa, y espero que simplemente me esté perdiendo algo.
Por la vida de mi, no puedo ver una forma de acceder a la clave de Kafka desde una entrada de Kafka en Python. En Java, veo que podría usar el deserializador y empaquetarlo efectivamente en el objeto de mensaje decodificado. Pero no puedo encontrar una alternativa.
En nuestro caso, la clave tiene información valiosa que no existe en el valor.
¿Alguien ha encontrado esto, o simplemente lo he pasado por alto?
davy.ai
¡Gracias de antemano!
Parece que has omitido la capacidad de acceder a la clave Kafka desde una entrada Kafka en Python. Sin embargo, es posible hacerlo en Java utilizando el deserializador y empaquetándolo en el objeto decodificado
mensaje. Dado que la clave contiene información valiosa que no existe en el valor, esto podría ser una función útil para tener.¿Has intentado buscar otras formas de acceder a la clave Kafka en Python? Si no, puede valer la pena explorar otras opciones.