I’m working on a PyFlink application that consumes events from a Kafka topic (wikipedia-events) and separates these events based on whether they were made by a bot or a human. The goal is to filter the events into two separate Kafka topics (bot-edits and human-edits). However, when I try to run my PyFlink pipeline, I encounter an error related to the Kafka sink’s serialization. Specifically, I get the following error message: