flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Tzu-Li (Gordon) Tai (JIRA)" <j...@apache.org>
Subject [jira] [Created] (FLINK-6520) FlinkKafkaConsumer09+ does not overwrite props to not auto commit offsets when commit mode is OffsetCommitMode.ON_CHECKPOINTS
Date Wed, 10 May 2017 10:09:04 GMT
Tzu-Li (Gordon) Tai created FLINK-6520:
------------------------------------------

             Summary: FlinkKafkaConsumer09+ does not overwrite props to not auto commit offsets
when commit mode is OffsetCommitMode.ON_CHECKPOINTS
                 Key: FLINK-6520
                 URL: https://issues.apache.org/jira/browse/FLINK-6520
             Project: Flink
          Issue Type: Bug
          Components: Kafka Connector
            Reporter: Tzu-Li (Gordon) Tai
            Assignee: Tzu-Li (Gordon) Tai


When the determined offset commit mode is `OffsetCommitMode.ON_CHECKPOINTS`, FlinkKafkaConsumer's
need to overwrite whatever setting was set by the user in the config properties to disable
automatic offset committing through the Kafka client.

This is properly done in the 0.8 consumer, but not in the 0.9+ consumers.



--
This message was sent by Atlassian JIRA
(v6.3.15#6346)

Mime
View raw message