[jira] [Created] (FLINK-6520) FlinkKafkaConsumer09+ does not overwrite props to not auto commit offsets when commit mode is OffsetCommitMode.ON_CHECKPOINTS

[Shang Yuanchun (Jira)]

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)