Python Examples for running Apache Flink® Table API on Confluent Cloud
-
Updated
Oct 3, 2026 - Python
#
flink-sql
Here are 18 public repositories matching this topic...
Apache Flink examples designed to be run by AWS Kinesis Data Analytics (KDA).
-
Updated
Nov 6, 2025 - Python
Helps explain how Flink handles late arriving data and the effects on message order
-
Updated
May 13, 2026 - Python
Real-time GPU cost governance on Confluent Cloud for Apache Flink — energy-per-useful-token (J/1k) detection, forecasting & a closed remediation loop. Measured on IBM Granite-3.3-8B / NVIDIA L4.
real-time schema-registry gpu stream-processing forecasting apache-flink apache-kafka anomaly-detection finops confluent-cloud flink-sql opentelemetry stream-governance vllm cost-governance llm-inference nvidia-dcgm gpu-cost
-
Updated
Sep 21, 2026 - Python
学习项目：MySQL → CDC → Kafka → Flink SQL → ClickHouse 电商实时数仓，单机 docker compose 可完整跑通
-
Updated
Sep 19, 2026 - Python
Real-time gaming analytics pipeline — Kafka 4.0 + Flink 2.0 SQL + ClickHouse. Fully containerised with Docker Compose.
python docker streaming kafka clickhouse data-engineering apache-kafka flink data-pipeline real-time-analytics flink-sql
-
Updated
Mar 29, 2026 - Python
A Kubernetes operator that manages FlinkSQL Studio deployments as first-class CRDs — deploy, configure, and lifecycle-manage FlinkSQL Studio instances
-
Updated
May 4, 2026 - Python
Engaging, interactive visualizations crafted with Streamlit, seamlessly powered by Apache Flink in batch mode to reveal deep insights from data.
kafka apache-flink flink iceberg apache-iceberg flink-sql streamlit streamlit-dashboard pyflink aws-glue-data-catalog
-
Updated
Dec 1, 2024 - Python
Modern Flink 2.x + Kafka 4.x + Iceberg lakehouse demos with SQL, PyFlink, and Java.
postgres real-time kafka docker-compose stream-processing data-engineering minio apache-flink apache-kafka flink demos devcontainer cdc change-data-capture iceberg sql-gateway apache-iceberg flink-sql lakehouse pyflink
-
Updated
Oct 1, 2026 - Python
Matching card authorizations to settlements in Flink SQL, including the ones that arrive four days late and the ones that never arrive
-
Updated
Sep 19, 2026 - Python
Flink K8s Cluster Template
-
Updated
Sep 19, 2022 - Python
Real-time pipeline over Wikimedia's live edit firehose: Kafka + Flink SQL, event-time windows, MATCH_RECOGNIZE edit-war detection, exactly-once.
python real-time cep stream-processing data-engineering event-driven apache-flink apache-kafka kafka-streams exactly-once streaming-analytics flink-sql
-
Updated
Sep 22, 2026 - Python
End-to-end data pipeline: PostgreSQL CDC (Debezium) → Kafka → Flink SQL → OpenSearch (search) + Redis (features). Local Docker stack, sample data, and verification scripts.
redis kafka postgresql kafka-connector cdc real-time-analytics debezium docker-composer flink-stream-processing data-engineering-pipeline flink-sql opensearch-dashboards
-
Updated
Sep 25, 2025 - Python
Confluent Cloud demo: live OpenSky flight data -> Kafka -> Flink SQL, with Schema Registry.
-
Updated
Mar 31, 2026 - Python
Project to stream data in Avro format from Netflix Kaggle dataset to a Kafka topic in Confluent Cloud, then analyze it with Flink SQL.
-
Updated
Feb 1, 2025 - Python
Real-time energy telemetry pipeline on Confluent Cloud: Python producer, Kafka + Schema Registry (Avro), Flink SQL windowed power usage and overload alerts
python iot avro schema-registry stream-processing apache-flink apache-kafka confluent-cloud flink-sql
-
Updated
Sep 30, 2026 - Python
🍔 Build a production-grade data pipeline for food delivery, enabling real-time insights and features through PostgreSQL, Kafka, and Flink.
redis kafka postgresql kafka-connector cdc real-time-analytics debezium docker-composer flink-stream-processing data-engineering-pipeline flink-sql opensearch-dashboards
-
Updated
Oct 4, 2026 - Python
⚡ Real-time e-commerce lakehouse you can run on a laptop with one command: Kafka → Flink SQL → Apache Iceberg → Trino → Streamlit. Features exactly-once streaming, event-time watermarks, windowed aggregations, and a live dashboard that shows Iceberg snapshots, compaction and time travel.
python streaming etl docker-compose data-engineering event-driven apache-flink apache-kafka real-time-analytics trino apache-iceberg flink-sql streamlit lakehouse
-
Updated
Sep 29, 2026 - Python
Add this topic to your repo
To associate your repository with the flink-sql topic, visit your repo's landing page and select "manage topics."