Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-6520

FlinkKafkaConsumer09+ does not overwrite props to disable auto commit offsets when commit mode is OffsetCommitMode.ON_CHECKPOINTS

    Details

    • Type: Bug
    • Status: Closed
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: None
    • Fix Version/s: 1.3.0, 1.4.0
    • Component/s: Kafka Connector
    • Labels:
      None

      Description

      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.

        Attachments

          Activity

            People

            • Assignee:
              tzulitai Tzu-Li (Gordon) Tai
              Reporter:
              tzulitai Tzu-Li (Gordon) Tai
            • Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved: