MySQL>> flink-explore>> 返回
项目作者： codingdebugallday

项目描述 ：
基于canal/kafka conenct的mysql/oracle数据实时同步、flink rest api、flink sql以及udf
高级语言： Scala
项目地址: git://github.com/codingdebugallday/flink-explore.git


读取 oracle 到 kafka

kafka-connect-oracle

canal 读取 mysql 到 kafka

项目模块简介

  • flink-api-spring-boot-starter

    1.   基于flink rest api开发的spring boot starter，可上传/运行jar等一系列操作

  • flink-sql-platform

    1.   基于flink-api-spring-boot-starter以及flink sql，可执行sql以及使用jar或代码自动注册各种udf

  • flink-explore

    1.   flink常用connector，只需编写json配置即可从mysql/oracle（canal/kafka connector）实时同步到不同sink

  • user-behavior-analysis

    1.   flink实战项目--电商用户行为分析

示例

flink实时同步oracle数据到clickhouse

联系我