kafka-jira mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Oleg Kuznetsov (JIRA)" <j...@apache.org>
Subject [jira] [Created] (KAFKA-5696) SourceConnector does not commit offset on reconfiguration
Date Thu, 03 Aug 2017 20:12:01 GMT
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)

Mime
View raw message