This is an automated email from the ASF dual-hosted git repository.
lirui pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 6451a1f [FLINK-23111][runtime-web] Fix maven build node version,
several dependencies, and NOTICE
add 4c8f3a7 [FLINK-22914][connector/kafka] Use FLIP-27 KafkaSource in
table connector
No new revisions were added by this update.
Summary of changes:
docs/content.zh/docs/connectors/table/kafka.md | 5 +-
docs/content/docs/connectors/table/kafka.md | 5 +-
.../connectors/kafka/table/KafkaDynamicSource.java | 163 ++++++++++++++-------
.../kafka/table/KafkaDynamicTableFactory.java | 21 +--
.../table/UpsertKafkaDynamicTableFactory.java | 3 +-
.../kafka/table/KafkaDynamicTableFactoryTest.java | 77 ++++------
.../table/UpsertKafkaDynamicTableFactoryTest.java | 38 +++--
7 files changed, 186 insertions(+), 126 deletions(-)
