Hi, I have simple job that consumes events from Kafka topic and process events with filter/flat-map only(i.e. no aggregation, no windows, no private state)
The most important constraint in my setup is to continue processing no matter what(i.e. stopping for few seconds to cancel job and restart it with new version is not an option because it will take few seconds) I was thinking about Blue/Green deployment concept and will start new job with new fat-jar while old job still running and then eventually cancel old job How Flink will handle such scenario? What will happen regarding semantics of event processing in transition time? I know that core Kafka has consumer re-balancing mechanism, but I'm not too familiar with it any thought will be highly appreciated thanks in advance Igor
