该仓库专注于让读者秒懂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=getalbum&album_id=2038088622687469575#wechat_redirect

Examples for using Apache Flink® with DataStream API, Table API, Flink SQL and connectors such as MySQL, JDBC, CDC, Kafka.

Self-contained demo using Flink SQL and Debezium to build a CDC-based analytics pipeline. All you need is Docker! :whale:

This project demonstrates Real-Time streaming of CDC data from MySql to Apache Iceberg using Flink SQL Client for faster data analytics and machine learning workloads.

This demo shows how to stream data to cloud databases with Confluent. It includes fully-managed connectors (Oracle CDC, RabbitMQ, MongoDB Atlas), ksqlDB/Flink SQL as stream processing engine.

CDC with NiFi, Kafka Connect, Flink SQL, Cloudera Data in Motion

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

本案例为flink sql实现CDC mysql数据到Hudi，照官网案例整理。

Real-time CDC data pipeline with Apache Flink, SQL Server & PostgreSQL

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.

test

this project is developed to support sqlserver in low versin

flink-cdc-sql

Flink CDC demo using Flink SQL Client

It is a tool to create flinksql for flink automaticly.

No description available

No description available

No description available

No description available

Demonstrate Flink SQL and Flink CDC with TiDB and Kafka

No description available

No description available

No description available

🚀 Real-Time Data Streaming pipeline with Apache Flink: Implementing CDC pipeline from MySQL to PostgreSQL

CDC pipeline in java for a sql database using flink

This repository contains code to push CDC changes from Postgres to ES via Flink SQL

End-to-end data pipeline: PostgreSQL CDC (Debezium) → Kafka → Flink SQL → OpenSearch (search) + Redis (features). Local Docker stack, sample data, and verification scripts.

From transactional and mqtt real time telemetries to kafka, Flink SQL and Iceberg tables. A CDC from OLTP to OLAP with Duckdb queries

Flink CDC pipeline prototype for consuming Debezium Kafka topics and sinking to Parquet (S3/MinIO). Includes both SQL Client scripts and a PyFlink job attempt. Currently blocked by checkpoint directory errors in SQL Client and missing Python environment in JobManager container.

A lightweight, enterprise-grade streaming platform that bridges the gap between complex infrastructure and business insights. By leveraging CDC (Debezium) and Flink SQL, this pipeline transforms raw operational changes into queryable live tables in Apache Zeppelin, allowing analysts to derive instant value from "data-in-motion" using standard SQL