Flink Explore Save

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

Project README

读取 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

联系我

Open Source Agenda is not affiliated with "Flink Explore" Project. README Source: thestyleofme/flink-explore
Stars
49
Open Issues
7
Last Commit
1 year ago

Open Source Agenda Badge

Open Source Agenda Rating