Streamline Apache Kafka with Conduktor Platform. 🚀

Advanced Matrix Extensions (AMX) Guide

Feature demos, integration guides & hands-on labs/projects using Kpow, Flex, Kafka, Flink, Iceberg & more

Codebase for Continual Prototype Evolution (CoPE) to attain perpetually representative prototypes for online and non-stationary datastreams. Includes implementation of the Pseudo-Prototypical Proxy (PPP) loss.

Crypto market data aggregator for order books, trades, liquidations, and open interest by depth levels. Experimental toy project — unsuitable for production or ML training.

Basic RFID Reader over Serial Port

Apache Beam demo projects

GlassFlow Python SDK to publish and consume data to your pipelines at Glassflow.dev

Reward Penalty Weighted Ensemble approach for multimodal data stream classification

ChatBox using PubNub

Wire is a distributed open source stream processing framework with powerful stream and batch-processing capabilities.[UNDER DEVELOPEMENT]

This Github Action lets you automate GlassFlow pipelines deployments as code

a I declare WAR card game exploring API, Promises, and Callbacks

This Bikesharing ETL Pipeline project is a data engineering solution designed to automate the process of ETL Capital Bikeshare trip data. A comprehensive data pipeline that handles large-scale data processing, and enables real-time data analysis was built.

S3 bucket to Kinesis data stream using lambda functions

This repository contains code snippets for a backend platform that calculates real-time taxi fares based on comfort levels. It leverages Kafka for data streaming, ElasticSearch for indexing, and BigQuery for revenue analysis, computing fares by analyzing driver-customer distances, categorized by comfort level and location.

StreamFlake: Real-Time CDC Pipeline with Kafka and Snowflake

- Data streaming application using spring cloud function, kafka streams and reactjs - Spring Cloud Function to write once and deploy to serverless and kubernetes

This is a real-time chat application designed for seamless communication between users.

Developing a data pipeline to stream user data from a user generator API, apply necessary transformations, and seamlessly insert the processed data into a storage system

Test of the drift classifiers implemented in MOA

Building a client server model to forward data using UDP Port from server to another using a connecting server in the middle.

Stream customer records from a CSV file to a Kafka topic using the Confluent Kafka Python client. A practical demo of real-time data ingestion.

A Java-based benchmark to test the performance of various sketches.

GitHub Events Analytics: End-to-End Streaming Project

Beginner example of datastreaming

Streaming data from data related to a certain topic.