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

Set offset commit only if group id is configured for new Kafka Table source

    XMLWordPrintableJSON

Details

    Description

      As https://issues.apache.org/jira/browse/FLINK-17619 described,

      the new Kafka Table source exits same problem and should fix too.

      note: this  fix both for master and release-1.11

       

      Attachments

        Issue Links

          Activity

            People

              leonard Leonard Xu
              leonard Leonard Xu
              Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: