Flink系列之：Debezium采集Mysql数据库表数据到Kafka Topic，同步kafka topic数据到StarRocks数据库
Posted 最笨的羊羊
tags:
篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了Flink系列之：Debezium采集Mysql数据库表数据到Kafka Topic，同步kafka topic数据到StarRocks数据库相关的知识，希望对你有一定的参考价值。
Flink系列之：Debezium采集mysql数据库表数据到Kafka Topic，同步kafka topic数据到StarRocks数据库
- 一、需求背景
- 二、Debezium采集Mysql数据
- 三、确定mysql表结构
- 四、StarRocks数据库创建表
- 五、flink pom.xml
- 六、flink sql创建kafka connector
- 七、flink sql创建StarRocks connector
- 八、flink SQL消费kafka topic数据完整代码
- 九、flink sql插入数据到StarRocks数据库两种方法
- 十、flink SQL消费kafka topic数据并存储到StarRocks完整代码
- 十一、mysql数据库插入数据，查看StarRocks数据库数据
一、需求背景
- Debezium采集Mysql数据库表数据到Kafka Topic
- 实时同步kafka to
以上是关于Flink系列之：Debezium采集Mysql数据库表数据到Kafka Topic，同步kafka topic数据到StarRocks数据库的主要内容，如果未能解决你的问题，请参考以下文章
Debezium系列之：安装部署debezium详细步骤，并把debezium服务托管到systemctl
Debezium系列之：debezium把sqlserver数据库多张表的数据发送到一个kafka topic