Hi,
Why StaticFileSplitEnumerator from FileSource does not track the already
processed files similar to how ContinuousFileSplitEnumerator does?

I'm thinking about scenario where we have a Bounded FileSource that reads a
lot of files using FileSource and stream it's content to Kafka.If there
will be a Job/cluster restart then we will process same files again.

Regards,
Krzysztof Chmielewski

Reply via email to