Description
I'm running SourceConnector, that reads files from storage and put data in kafka. I want, in case of reconfiguration, offsets to be flushed.
Say, a file is completely processed, but source records are not yet committed and in case of reconfiguration their offsets might be missing in store.
Is it possible to force committing offsets on reconfiguration?