Open-Source Web UI for Apache Kafka Management

Pravega - Streaming as a new software defined storage primitive

Open-Source Web UI for managing Apache Kafka clusters

Full stack application platform for building stateful microservices, streaming APIs, and real-time UIs

Source code for the Kafka Streams in Action Book

A Java Toolbox for Scalable Probabilistic Machine Learning

All code samples, scripts and more in-depth examples for The Apache Ignite Book. Include Apache Ignite 2.6 or above

Euphoria is an open source Java API for creating unified big-data processing flows. It provides an engine independent programming model which can express both batch and stream transformations.

An example for streaming large files in chunks using StreamingResponseBody in Spring MVC

Sample Applications for Pravega.

Window-Based Hybrid CPU/GPU Stream Processing Engine

An OPC UA player that support replaying OPC UA data from file

Apache Flink/Apache Kafka streaming data analytics demonstration using Streaming Synthetic Sales Data Generator

kafka-producer-consumer-with-spring-boot

Demonstration of streaming applications using Spring Cloud Data Flow with microservices written in Spring Cloud Stream.

Parallel Streaming Transformation Loader

Apache Kafka Streams streaming data analytics demonstration using Streaming Synthetic Sales Data Generator

🤺 coding challenge from Insight Data Engineering Program 💯

Adaptive Decision Forest(ADF) is an incremental machine learning framework called to produce a decision forest to classify new records. ADF is capable to classify new records even if they are associated with previously unseen classes. ADF also is capable of identifying and handling concept drift; it, however, does not forget previously gained kn…

Reservoir Sampling for Group-By Queries in Flink Platform. Answering effectively Single Aggregate.