Send key in Flink Kafka Producer with Python
Here is my Python code where I’m trying to produce a message with my custom setup, but I’m encountering the mentioned error. Could anyone please help me with creating the correct set_key_serialization_schema?