LarkMidTable 是一站式开源的数据中台，实现中台的 基础建设，数据治理，数据开发，监控告警，数据服务，数据的可视化，实现高效赋能数据前台并提供数据服务的产品。

该仓库专注于让读者秒懂Flink组件，包含Flink实战代码和文档、200个Flink教程知识点，Flink Datastream、Flink Table、Flink Window、Flink State、Flink Checkpoint、Flink Metrics、Flink Memory、Flink on standalone /yarn/k8s、Flink SQL、Flink CEP、Flink CDC、Flink UDF、PyFlink、Flink新特性、Flink Partition、Flink Memory等知识点。详细链接请看：https ://mp.weixin.qq.com/mp /appmsgalbum?__biz=Mzg5NDY3NzIwMA==&action=g…

CDC（变化数据捕获）实时同步方案，秒级延迟。

一个基于 Flink CDC 的 CDC 框架，mysql，binlog

基于Table/SQL API的轻量级Flink CDC应用

Dameng Connector 是一个专门为达梦数据库(DM Database)设计的变更数据捕获(CDC)解决方案。该项目通过扩展 Debezium 和 Flink CDC，实现了对达梦数据库的实时数据变更监控、捕获和处理能力，为数据集成、数据同步、实时分析等场景提供强大支持。

数据中台建设、离线数仓建设、实时数仓建设、数据湖建设、区块链技术应用。组件包括但不限于：flink/spark/hadoop/hive/kafka/doris/kudu/clickhouse

it's a simple podcase app poc.

⚡ 数据集成 | DataLink is a lightweight data integration framework build on top of DataX, Spark and Flink

A [single|uber|fat] jar standalone Apache Flink connected to PostgreSQL via Ververica CDC connector. Usage Flink SQL to replicate data from PostgreSQL to Elasticsearch/something else.

基于 Apache Flink® CDC Connectors 的数据实时同步解决方案

flink-cdc is fucking god damn it awesome

BigData, OLAP ...

Flink CDC is a streaming data integration tool

CDC(Change Data Capture) is made up of two components, the CDD and the CDT. CDD is stand for Change Data Detection and CDT is stand for Change Data Transfer.

Demo for oracle cdc streaming to mongo db using apache flink