Statefun with no Protobuf ingress and egress

Hi, I have a very simple schema where one python statefun application reads from a kafka topic and writes in another kafka topic, those topics are produced and consumed with another python script as it is done in the Python Flink Walkthrough

Problem with kafka with key=None using pyhton-kafka module

Hello, I am following the example in Python Walkthrough , I downloaded the zip file with the project skeleton. I'm having a problem when changing the key attribute in