Hi, I'm building a small application which reads CSV-files from Kafka and passes them to Flink. In Flink i parse these values which contains an embedded timestamp and assign watermarks with a BoundedOutOfOrdernessTimestampExtractor. Then i "transform" the stream into a KeyedStream by an ID embedded in the datavalue. These are later processed by CEP. However since the timestamps may differ depending on extracted ID I would like to have a seperate watermark for each ID in the keyed stream before they are processed in CEP. Is this possible and in that case how do i procceed? Any help would be appreciated.
Best, Björn