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.

        Activity

        Hide
        tzulitai Tzu-Li (Gordon) Tai added a comment -

        Fixed for 1.3 via 2708f6d9a4b74c35c598146765d4a188452f323e
        Fixed for master via 6fdec897d4b247975587895fa2186e37fe37b970

        Show
        tzulitai Tzu-Li (Gordon) Tai added a comment - Fixed for 1.3 via 2708f6d9a4b74c35c598146765d4a188452f323e Fixed for master via 6fdec897d4b247975587895fa2186e37fe37b970

          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:

              Development