data-streaming
There are 107 repositories under data-streaming topic.
strimzi/strimzi-kafka-operator
Apache Kafka® running on Kubernetes
superstreamlabs/memphis
Memphis.dev is a highly scalable and effortless data streaming platform
apache/inlong
Apache InLong - a one-stop, full-scenario integration framework for massive data
linkedin/brooklin
An extensible distributed system for reliable nearline data streaming at scale
TouK/nussknacker
Low-code tool for automating actions on real time data | Stream processing for the users.
getindata/flink-http-connector
Http Connector for Apache Flink. Provides sources and sinks for Datastream , Table and SQL APIs.
DagsHub/client
DagsHub client libraries
getindata/dbt-flink-adapter
Adapter for dbt that executes dbt pipelines on Apache Flink
eserie/wax-ml
A Python library for machine-learning and feedback loops on streaming data
pravega/pravega-samples
Sample Applications for Pravega.
build-on-aws/building-apache-kafka-connectors
Sample code that shows the important aspects of developing custom connectors for Kafka Connect. It provides the resources for building, deploying, and running the code on-premises using Docker, as well as running the code in the cloud.
strimzi/strimzi-canary
Strimzi canary
KentHsu/Udacity-Data-Streaming-Nanodegree
Udacity Data Streaming Nanodegree Program
marian-nmt/sotastream
A library for data streaming and augmentation
jaehyeon-kim/kafka-pocs
Apache Kafka and Related Projects
jaehyeon-kim/flink-demos
Apache Flink (Pyflink) and Related Projects
officialarijit/Fed-ReMECS-mqtt
A Federated Learning Method for Real-time Emotion State Classification from Multi-modal Streaming
ppatierno/kafka-hybrid-iot
Apache Kafka for the Hybrid IoT
jlumbroso/python-random-hash
A simple, time-tested, family of random hash functions in Python, based on CRC32 and xxHash, affine transformations, and the Mersenne Twister. 🎲
MasWag/monaa
A Tool for Timed Patten Matching with Automata-Based Acceleration
PubNubDevelopers/Real-Time-Data-Streaming-Demo
Demonstration of PubNub's real-time data streaming capabilities from Twitter, Wikipedia & more
apache/doris-kafka-connector
Kafka Connector for Apache Doris
blitzkz23/final-project-end-to-end-banking-campaign-pipeline
Final Project for IYKRA Data Fellowship 8 Program, creating an end-to-end banking campaign pipeline using lambda architecture (providing acess to batch and stream processing)
goldsmocap/mocap-streamer
Goldsmiths Mocap Streamer is a cutting-edge tool that streams live motion capture (BVH) data over the internet, allowing users from multiple remote locations to interact in the same shared digital space.
jlumbroso/java-random-hash
A simple, time-tested, family of random hash functions in Java, based on CRC32, affine transformations, and the Mersenne Twister. 🎲
zabir-nabil/picast
A lightweight fast data streaming library for raspberry pi in python.
ProjectIxian/Ixian-S2
Ixian S2 end to end data streaming network software
sorieux/trino-kafka-demo
Hands-on demo for querying Kafka streams using SQL with Trino and data integration with PostgreSQL.
turulix/memphis-rust-community
A Memphis SDK written in rust.
ambarltd/ambar_demo
An at your own pace demonstration of the technology that powers Ambar! Checkout the ReadMe for details on how to get started.
kanenorman/mobility-ai
Full Stack Machine Learning Engineer Project - Real Time Data Streaming and Predictions
officialarijit/RPWE
Reward Penalty Weighted Ensemble approach for multimodal data stream classification
ThiagoBarradas/logstash-beats-demo
Elastic Stack with Nginx, Logstash and Beats demo
aymane-maghouti/Real-Time-Data-Pipeline-Using-Kafka
This project implements a real-time data pipeline using Apache Kafka, Python's psutil library for metric collection, and SQL Server for data storage. The pipeline collects metrics data from the local computer, processes it through Kafka brokers, and loads it into a SQL Server database. Additionally, a real-time dashboard is created using Power BI.
tealtools/dekaf
Dekaf is a visual user interface for Apache Pulsar 🛸
the-timoye/songstreams
Streams simulated events using Kafka & Spark, from a music application to a data lake (AWS S3), and then a warehouse (AWS Redshift)