flink-sql topic

Open data platform based on Kubernetes. Scaleph supports SeaTunnel、Flink and Doris backended by SeaTunnel on Flink engine、Flink Kubernetes Operator and Doris operator.

flowerfine

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

xuanbo

基于Apache-bahir-kudu-connector的flink-connector-kudu，支持Flink1.11.x DynamicTableSource/Sink，支持Range分区等

collabH

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

morsapaes

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

twalthr

Asynchronous flink connector based on the Lettuce, supporting sql join and sink, query caching and debugging.

jeff-zou

Write ETL using your favorite SQL dialects

SharpData

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.

confluentinc

Http Connector for Apache Flink. Provides sources and sinks for Datastream , Table and SQL APIs.

getindata