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, . . . Read more