For example, I want to merge two kafka topics (named topicA and topicB) by the specific key with a max timeout. I use event time and class BoundedOutOfOrdernessTimestampExtractor to generate water mark. When some partitions of topicA be delayed by backpressure, and the delays exceeds my max timeout. It results in all of my delayed partition in topicA (also corresponding data in topicB) can't be merged. What I want is if backpressure happens, consumers can only consume depends on my event time.
-- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/How-can-I-handle-backpressure-with-event-time-tp13313.html Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.
