Question: I’m building a Kafka -> Flink -> Kafka pipeline that works with delineated “session” data. My input Kafka topic has data in the following format and constitutes one session for session_key: Each session like this is about 100 events ...