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)
