flinksql kafka connector 两表join demo视频

最新推荐文章于 2025-03-31 18:09:44 发布

Thomas2143

最新推荐文章于 2025-03-31 18:09:44 发布

阅读量415

点赞数

分类专栏：总结文章标签： flink sql kafka

本文链接：https://blog.csdn.net/qq_35515661/article/details/121004645

版权

总结专栏收录该内容

792 篇文章 ¥99.90 ¥299.90

订阅专栏

该视频演示了如何使用Flink SQL将Kafka主题的数据映射到虚拟表，并进行多表JOIN操作。虽然未展示数据写回Kafka Topic的过程，但提到了只需创建另一张虚拟表并配置Kafka Topic，通过INSERT语句即可实现。

摘要生成于 C知道，由 DeepSeek-R1 满血版支持，前往体验 >

目的

就是简单演示一下 flink可以把kafka topic中的数据映射到flinksql中的一张虚拟表,然后可以基于kafka连接器做多表jion,甚至写入到kafkatopic. 视频中没有演示写入到kafkatopic. 只需要再create一张虚拟表,并配置kafkatopic,然后使用insert语句即可插入.

视频中文本内容

-- 下面两个建表语句是把kafka topic数据映射到flink1.13-sql中的虚拟表
-- 然后对其做个简单的join看一下效果
-- 这是实时报表或者实时数仓的一个起步demo. 

drop table if exists tb1;
CREATE TABLE tb1 (
  name string,
  age int
) WITH (
  'connector' = 'kafka',
  'topic' = 'me',
  'properties.bootstrap.servers' = '192.168.9.99:9092',
  'properties.group.id' = 'test',
  'format' = 'csv',
  'scan.startup.mode' = 'earliest-offset' 
);

drop table if exists tb2;
CREATE TABLE tb2 (
  name string,
  fatherName string
) WI

了解本专栏