用flinksql cdc 直连就行了
https://nightlies.apache.org/flink/flink-docs-release-1.12/dev/table/connectors/kafka.html
单身狗
最近话题
- 超详细 python 学习笔记,python 基础
- Cassandra 操作
- Cassandra 缓存数据库简介
- iceberg 学习笔记,奶牛野牛,奶牛就到此一游
- Tigergraph 图数据库学习-安装
- Tigergraph 图数据库学习-gsql
- Neo4j 图数据库
- Flink 调优 (学习)
- 欧洛米修斯监控 k8s
- k8s 学习单机部署
- k8s 虚拟机高可用部署
- 实时推荐项目,练习 demo
- 设计模式
- JUC2022 新版
- Apache Pulsar 初级使用
- JUC2021 版
- 数据湖 HUDI-Spark 03
- 数据湖 HUDI-FLINK 02
- 数据湖 HUDI 基本概念 01
- Docker 完整版
最新评论
- flink 连 kafka 的方式是什么?直连还是?
- 我照着海牛的视频部署集群,结果配置到 myql 的时候报错
- jar 包打包失败,试了一晚上了,也没大成功?
- jar 包打包失败,试了一晚上了,也没大成功?
- 最简单高效的 JSON 转 CSV
- 企业级 NGINX 配置 1
- 企业级 NGINX 配置 2
- HIVE 基础-->安装,建表 (前两天)
-
信息被删除或无权限查看
- java jar 包启动 shell 脚本
-
信息被删除或无权限查看
-
信息被删除或无权限查看
-
信息被删除或无权限查看
-
信息被删除或无权限查看
-
信息被删除或无权限查看
- PostgreSQL 数据库函数
- 为啥静态类(不是内部类)不能被实例化呢?
- 为啥静态类(不是内部类)不能被实例化呢?
- 为啥静态类(不是内部类)不能被实例化呢?
- hadoop 集群上