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.

Yet Another UserAgent Analyzer

Low-code tool for automating actions on real time data | Stream processing for the users.

[DEPRECATED] Kubernetes operator for managing the lifecycle of Apache Flink and Beam applications.

FeatHub - A stream-batch unified feature store for real-time machine learning

Elastic data processing with Apache Pulsar and Apache Flink

Dagger is an easy-to-use, configuration over code, cloud-native framework built on top of Apache Flink for stateful processing of real-time streaming data.

Distributed Temporal Graph Analytics with Apache Flink

A data generator source connector for Flink SQL based on data-faker.

Kubernetes operator for managing the lifecycle of Apache Flink and Beam applications.

flink-tensorflow - TensorFlow support for Apache Flink

A complete example of a big data application using : Kubernetes (kops/aws), Apache Spark SQL/Streaming/MLib, Apache Flink, Scala, Python, Apache Kafka, Apache Hbase, Apache Parquet, Apache Avro, Apache Storm, Twitter Api, MongoDB, NodeJS, Angular, GraphQL

Framework for Apache Flink unit tests

A tool that help automate deployment to an Apache Flink cluster

flink-sql 在 flink 上运行 sql 和 构建数据流的平台 基于 apache flink 1.10.0

Simple stream processing pipeline

flink-jpmml is a fresh-made library for dynamic real time machine learning predictions built on top of PMML standard models and Apache Flink streaming engine

Adapter for dbt that executes dbt pipelines on Apache Flink

Kryptonite for Kafka is a client-side 🔒 field level 🔓 cryptography library for Apache Kafka® offering an Apache Kafka Connect SMT, ksqlDB UDFs, Apache Flink® UDFs, and a standalone HTTP API service. It's an UNOFFICIAL community project.

A curated list of Pulsar tools, integrations and resources.