In 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

Reply via email to