flink

Share spot for Multi Device and Multi AI work with Cloudera Streaming Operators

Self-service data ingest: tenant YAML → Terraform → Kafka/Connect, Flink to Iceberg. Strimzi on Kind, failure drills, MSK slice.

🤖 Build and prototype custom coding agents with this self-hostable quickstart app, inspired by Claude Code for agile development.

The Bootstrapping & Reliability Framework for Apache Flink. Fail fast on configuration, serialize natively without Kryo, and bootstrap stream pipelines with zero boilerplate.

🛠️ Manage multiple WeChat instances on macOS effortlessly with this interactive tool, offering smart detection and flexible control for a seamless experience.

Turn existing OpenTelemetry telemetry into a live, lifecycle-managed typed property graph.

Streaming data platform (Kafka→Flink→Iceberg/DuckDB→FastAPI) serving live, typed business metrics — measured 1.06 s p50 / 1.99 s p95 event-to-metric freshness. Python & TypeScript SDKs. · Стриминговая платформа данных: живые типизированные бизнес-метрики, замеренная свежесть 1.06 s p50 / 1.99 s p95 от события до метрики. SDK на Python и TypeScript.

GitOps repository for use with Confluent Platform deployments on Kubernetes

Apache Flink

Flink TUI

k-shui — Kafka Streaming Hub UI. Open-source control center for Apache Kafka: topics, messages, schemas, Connect, ksqlDB, Flink, metrics, lineage & alerts in one modern UI.

Apache Paimon is a lake format that enables building a Realtime Lakehouse Architecture with Flink and Spark for both streaming and batch operations.

Sample application with 16 microservices showcasing Distributed Systems concepts, Kubernetes and gRPC.

Dockerized runner, utilities, and functions for FlinkSQL applications

Benchmarks for Nussknacker - A visual tool to define and run real-time decision algorithms. Brings agility to business teams, liberates developers to focus on technology.

Apache Flink Website

A sample project demonstrating a real-time streaming data processing pipeline using Apache Kafka, Apache Flink (PyFlink), and PostgreSQL. Simulated sensor data is continuously generated and sent to Kafka

Apache flink

Apache Amoro(incubating) is a Lakehouse management system built on open data lake formats.

基于 antlr4 的多种数据库SQL解析器，获取SQL中元数据，可用于数据平台产品中的多个场景：ddl语句提取元数据、sql 权限校验、表级血缘、sql语法校验等场景。支持spark、flink、gauss、starrocks、Oracle、MYSQL、Postgresql，sqlserver,、db2等