Skip to content

基于canal/kafka conenct的mysql/oracle数据实时同步、flink rest api、flink sql以及udf

Notifications You must be signed in to change notification settings

thestyleofme/flink-explore

Folders and files

NameName
Last commit message
Last commit date

Latest commit

 

History

42 Commits
 
 
 
 
 
 
 
 
 
 

Repository files navigation

flink-explore

读取 oracle 到 kafka

kafka-connect-oracle

canal 读取 mysql 到 kafka

项目模块简介

  • flink-api-spring-boot-starter

      基于flink rest api开发的spring boot starter,可上传/运行jar等一系列操作
    
  • flink-sql-platform

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

      flink常用connector,只需编写json配置即可从mysql/oracle(canal/kafka connector)实时同步到不同sink
    
  • user-behavior-analysis

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

示例

flink实时同步oracle数据到clickhouse

联系我

About

基于canal/kafka conenct的mysql/oracle数据实时同步、flink rest api、flink sql以及udf

Topics

Resources

Stars

Watchers

Forks

Releases

No releases published

Packages

No packages published