Stopping a kafka consumer gracefully (no losing of inflight events, StoppableFunction)

Posted by Bart Kastermans on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/Stopping-a-kafka-consumer-gracefully-no-losing-of-inflight-events-StoppableFunction-tp18418.html

In https://ci.apache.org/projects/flink/flink-docs-release-1.4/ops/cli.html it is shown that
for gracefully stopping a job you need to implement the StoppableFunction interface.  This
appears not (yet) implemented for Kafka consumers.  Am I missing something, or is there a
different way to gracefully stop a job using a kafka source so we can restart it later without
losing any (in flight) events?

- bart