【Flink】FlinkSQL实现数据从Kafka到MySQL |
您所在的位置:网站首页 › flinksql读取kafka中历史数据 › 【Flink】FlinkSQL实现数据从Kafka到MySQL |
简介
未来Flink通用化,代码可能就会转换为sql进行执行,大数据开发工程师研发Flink会基于各个公司的大数据平台或者通用的大数据平台,去提交FlinkSQL实现任务,学习Flinksql势在必行。 本博客在sql-client中模拟大数据平台的sql编辑器执行FlinkSQL,使用Flink实现数据从Kafka传输到MySQL具体操作,这个在生产开发中比较常用,通常生产用kafka作为数据的输入,本例子Flink版本1.13.6,具体操作如下: 创建mysql测试目标表下面是创建mysql测试目标表的例子 CREATE TABLE `kafka_target` ( `id` int(11) unsigned NOT NULL AUTO_INCREMENT COMMENT '自增ID', `name` varchar(64) DEFAULT NULL COMMENT '姓名', `create_time` datetime COMMENT '创建时间', PRIMARY KEY (`id`) ) ENGINE = InnoDB; 创建kafka的topic/opt/kafka/bin/kafka-topics.sh --create --bootstrap-server 192.168.0.1:9092 --replication-factor 1 --partitions 1 --topic mysqlsource 可执行FlinkSQL(sql-client中执行)注意在执行Fli |
今日新闻 |
推荐新闻 |
CopyRight 2018-2019 办公设备维修网 版权所有 豫ICP备15022753号-3 |