I am building a Flink Project using Python that streams events from a Kafka topic. The payload in the topics has been encoded and the SimpleStringSchema is unable to decode them. I have create a custom Deserializer that can decode the messages and added it to the KafkaSource but I get the following error when I run the code: