The Apache Kafka Operations 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.
Cross-exchange crypto market data and feature-engineering toolkit for order books, trades, open interest, funding, liquidations, and options. Python research prototype with lessons on fixed-time bars and ML.
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
Real-time edge data visualization with Grafana and Litmus Edge
A production-ready Model Context Protocol (MCP) server for Apache Kafka. Features Information Flow Control (IFC) sandboxing, granular namespace isolation, and strict bounded buffers to securely bridge autonomous AI agents with enterprise streaming infrastructure.
This Github Action lets you automate GlassFlow pipelines deployments as code
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.
a I declare WAR card game exploring API, Promises, and Callbacks
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
S3 bucket to Kinesis data stream using lambda functions
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
To associate your repository with the datastreaming topic, visit your repo's landing page and select "manage topics."