🍔 Build a production-grade data pipeline for food delivery, enabling real-time insights and features through PostgreSQL, Kafka, and Flink.
Write Flink streaming pipelines as composable JSX components. Synthesizes to Flink SQL + Kubernetes FlinkDeployment CRDs.
Java Examples for running Apache Flink® Table API on Confluent Cloud
Helps explain how Flink handles late arriving data and the effects on message order
Real-time monitoring dashboard and GraphQL server for Apache Flink clusters — job management, blue-green deployments, SQL Gateway, and pluggable instruments.
Real-time gaming analytics pipeline — Kafka 4.0 + Flink 2.0 SQL + ClickHouse. Fully containerised with Docker Compose.
Asphalt is a development project designed to process GTFS data in real time and compute traffic metrics.
A Kubernetes operator that manages FlinkSQL Studio deployments as first-class CRDs — deploy, configure, and lifecycle-manage FlinkSQL Studio instances
Python Examples for running Apache Flink® Table API on Confluent Cloud
End-to-end Kafka ecosystem lab: streaming, monitoring, connectors, security and more.
Http Connector for Apache Flink. Provides sources and sinks for Datastream , Table and SQL APIs.
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.
Examples of Apache Flink® v2.1 applications showcasing the DataStream API, Table API in Java and Python, and Flink SQL, featuring AWS, GitHub, Terraform, Streamlit, and Apache Iceberg.
The Apache Flink SQL Cookbook is a curated collection of examples, patterns, and use cases of Apache Flink SQL. Many of the recipes are completely self-contained and can be run in Ververica Platform as is.
Flink SQL extension for Visual Studio Code
Add a description, image, and links to the flink-sql topic page so that developers can more easily learn about it.
To associate your repository with the flink-sql topic, visit your repo's landing page and select "manage topics."