Flink读写Kafka（Table API）
前面（Flink读写Kafka（DataStream API）_flink kafka scram-CSDN博客）我们已经讲解了使用DataStream API来读取Kafka，在这里继续讲解下使用Table API来读取Kafka，和前面一样也是引入相同的依赖即可。
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-connector-kafka</artifactId>
<version>1.15.4</version>
</dependency>
1. 创建Kafka Table
可以使用以下方式来创建Kafka表：
CREATE TABLE KafkaTable (
`event_time` TIMESTAMP(3) METADATA FROM 'timestamp'
原文地址：https://blog.csdn.net/chanyue123/article/details/145253344
免责声明：本站文章内容转载自网络资源，如侵犯了原著者的合法权益，可联系本站删除。更多内容请关注自学内容网（zxcms.com）！