[jira] [Created] (KAFKA-5696) SourceConnector does not commit offset on reconfiguration

[Oleg Kuznetsov (JIRA)]

Oleg Kuznetsov created KAFKA-5696:
-------------------------------------

             Summary: SourceConnector does not commit offset on reconfiguration
                 Key: KAFKA-5696
                 URL: https://issues.apache.org/jira/browse/KAFKA-5696
             Project: Kafka
          Issue Type: Bug
          Components: KafkaConnect
            Reporter: Oleg Kuznetsov
             Fix For: 0.10.0.2


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?



--
This message was sent by Atlassian JIRA
(v6.4.14#64029)