GitOps repository for use with Confluent Platform deployments on Kubernetes

Large language model in the terminal! Less `--help` and `man` and more getting stuff done

Apache Fluss is a streaming storage built for real-time analytics.

Amazon MSK + event sourcing demo

Sample Apache Flink application that can be deployed to Amazon Managed Service for Apache Flink. It reads taxi events from a Kinesis data stream, processes and aggregates them, and ingests the resu…

Example applications in Java, Python and SQL for Kinesis Data Analytics, demonstrating sources, sinks, and operators.

Sample Apache Flink application that can be deployed to Kinesis Analytics for Java. It reads taxi events from a Kinesis data stream, processes and aggregates them, and ingests the result to an Amaz…

Collection of code examples for Amazon Managed Service for Apache Flink

Kinesis Data Analytics Blueprints are a curated collection of Apache Flink applications. Each blueprint will walk you through how to solve a practical problem related to stream processing using Apa…

Streaming ETL with Apache Flink and Amazon Kinesis Data Analytics

Efficient reliable UDP unicast, UDP multicast, and IPC message transport

Advanced Bloom Filter Based Algorithms for Efficient Approximate Data De-Duplication in Streams

Docker packaging for Apache Flink

Event-sourced Twitter clone built on Apache Flink

COVID-19 Italia - Monitoraggio situazione

Code snippets from the Streaming Systems book (streamingbook.net).

Genomics England PanelApp - A crowdsourcing tool to allow gene panels to be shared, downloaded, viewed and evaluated by the Scientific Community

Scala DSL for Unit-Testing Processing Topologies in Kafka Streams

Original Apollo 11 Guidance Computer (AGC) source code for the command and lunar modules.