Flink Tutorial Project

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

This repository provides Scotty, a framework for efficient window aggregations for out-of-order Stream Processing.

Streaming machine learning using PyTorch, Flink, and ONNX

Is using KoP (Kafka-On-Pulsar) a good idea? Use the scenarios implemented in this repository to check whether Pulsar with KoP enabled is a good fit for your most common Kafka workloads.

The Dynamic Rules Engine is a serverless application that enables real-time evaluation of rules against sensor data, leveraging AWS Kinesis Data Streams, Amazon Managed Service for Apache Flink, and AWS Lambda.

A Comparative Evaluation of Spark and Flink Stream Processing.

Simple example for access count in Apache logs using Apache Flink

Setup for realtime data streaming using Kafka, Flink, Pinot, MySQL, Postgres and Superset

Real-time Twitter analytic dashboards with Apache Flink, Elasticsearch and Kibana.

Real-time parking management system with stream processing and analytics capabilities.

Agentic AI approach connecting 3 agents to do real-time credit score evaluations, interest rate calculation based on payment history, and auto-generation of letter of decisions

A distributed shared-nothing variant of the incremental stochastic gradient descent algorithm

WIP Serverless Streaming Analytics data pipeline composed of AWS Kinesis Data Streams, AWS Kinesis Data Analytics (Flink), AWS S3, AWS Lambda, Snowflake and Python components. Provisioned using Terraform.