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

Flink Kafka consumer should support auto-commit opt-outs

    Details

    • Type: Improvement
    • Status: Resolved
    • Priority: Critical
    • Resolution: Fixed
    • Affects Version/s: None
    • Fix Version/s: 1.3.0
    • Component/s: Kafka Connector
    • Labels:
      None

      Description

      Currently the Kafka source will commit consumer offsets to Zookeeper, either upon a checkpoint if checkpointing is enabled, otherwise periodically based on auto.commit.interval.ms

      It should be possible to opt-out of committing consumer offsets to Zookeeper. Kafka has this config as auto.commit.enable (0.8) and enable.auto.commit (0.9).

        Attachments

          Activity

            People

            • Assignee:
              tzulitai Tzu-Li (Gordon) Tai
              Reporter:
              shikhar Shikhar Bhushan
            • Votes:
              3 Vote for this issue
              Watchers:
              9 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved: