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

Use Kafka new source in Table/SQL connector

    XMLWordPrintableJSON

Details

    Description

      Currently the Kafka Table/SQL connector is still using the legacy Kafka SourceFunction. In order to align DataStream and Table/SQL API, the new Kafka source should also be used in Table/SQL connector.

      Attachments

        Issue Links

          causes

          Improvement - An improvement or enhancement to an existing feature or task. FLINK-24697 Kafka table source cannot change the auto.offset.reset setting for 'group-offsets' startup mode

          • Minor - Minor loss of function, or other problem where easy workaround is present.
          • Resolved
          links to

          Web Link GitHub Pull Request #16791

          Web Link GitHub Pull Request #16809

          There are no Sub-Tasks for this issue.

          Activity

            People

              renqs Qingsheng Ren
              renqs Qingsheng Ren
              Votes:
              0 Vote for this issue
              Watchers:
              7 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: