个人网站的版权怎么写,江苏省建设类高工申报网站,网易企业邮箱登入路口,仿网站视频教程前面(Flink读写Kafka(DataStream API)_flink kafka scram-CSDN博客)我们已经讲解了使用DataStream API来读取Kafka,在这里继续讲解下使用Table API来读取Kafka,和前面一样也是引入相同的依赖即可。 dependency groupIdorg.apache.flink/groupIddependency groupIdorg.apache.flink/groupId artifactIdflink-connector-kafka/artifactId version1.15.4/version /dependency 1. 创建Kafka Table
可以使用以下方式来创建Kafka表: CREATE TABLE KafkaTable ( `event_time` TIMESTAMP(3) METADATA FROM 'timestamp'