Qingsheng Ren created FLINK-22914: ------------------------------------- Summary: Use Kafka New Source in Table/SQL connector Key: FLINK-22914 URL: https://issues.apache.org/jira/browse/FLINK-22914 Project: Flink Issue Type: New Feature Components: Connectors / Kafka Reporter: Qingsheng Ren Fix For: 1.14.0
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. -- This message was sent by Atlassian Jira (v8.3.4#803005)