Trending repositories for topic stream-processing
Python ETL framework for stream processing, real-time analytics, LLM pipelines, and RAG.
Cross-platform, customizable ML solutions for live and streaming media.
Fast and Lightweight Logs, Metrics and Traces processor for Linux, BSD, OSX and Windows
FastStream is a powerful and easy-to-use Python framework for building asynchronous services interacting with event streams such as Apache Kafka, RabbitMQ, NATS and Redis.
Open-source graph database, tuned for dynamic analytics environments. Easy to adopt, scale and own.
Redpanda is a streaming data platform for developers. Kafka API compatible. 10x faster. No ZooKeeper. No JVM!
Lean and mean distributed stream processing system written in rust and web assembly. Alternative to Kafka + Flink in one.
A blazingly fast event stream processing library powering the reveald event processing daemon.
High-performance, low-footprint SQL database written in C++. Process millions of rows per second from Kafka/Pulsar, Iceberg, or ClickHouse, and seamlessly write results back. Supports powerful feature...
Danfo.js is an open source, JavaScript library providing high performance, intuitive, and easy to use data structures for manipulating and processing structured data.
Fast, Simple and a cost effective tool to replicate data from Postgres to Data Warehouses, Queues and Storage
A curated list of awesome System Design (A.K.A. Distributed Systems) resources.
A blazingly fast event stream processing library powering the reveald event processing daemon.
Python ETL framework for stream processing, real-time analytics, LLM pipelines, and RAG.
Open-source graph database, tuned for dynamic analytics environments. Easy to adopt, scale and own.
FastStream is a powerful and easy-to-use Python framework for building asynchronous services interacting with event streams such as Apache Kafka, RabbitMQ, NATS and Redis.
Fast and Lightweight Logs, Metrics and Traces processor for Linux, BSD, OSX and Windows
High-performance, low-footprint SQL database written in C++. Process millions of rows per second from Kafka/Pulsar, Iceberg, or ClickHouse, and seamlessly write results back. Supports powerful feature...
Lean and mean distributed stream processing system written in rust and web assembly. Alternative to Kafka + Flink in one.
Cross-platform, customizable ML solutions for live and streaming media.
Efficient, easy-to-use, and fast PHP JSON stream parser
Fast, Simple and a cost effective tool to replicate data from Postgres to Data Warehouses, Queues and Storage
Redpanda is a streaming data platform for developers. Kafka API compatible. 10x faster. No ZooKeeper. No JVM!
Danfo.js is an open source, JavaScript library providing high performance, intuitive, and easy to use data structures for manipulating and processing structured data.
🦖 Stateful Serverless Framework for Geo-distributed Edge AI Infra. with function calling support, write once, run on any model.
Python ETL framework for stream processing, real-time analytics, LLM pipelines, and RAG.
Cross-platform, customizable ML solutions for live and streaming media.
Fast and Lightweight Logs, Metrics and Traces processor for Linux, BSD, OSX and Windows
FastStream is a powerful and easy-to-use Python framework for building asynchronous services interacting with event streams such as Apache Kafka, RabbitMQ, NATS and Redis.
Redpanda is a streaming data platform for developers. Kafka API compatible. 10x faster. No ZooKeeper. No JVM!
Open-source graph database, tuned for dynamic analytics environments. Easy to adopt, scale and own.
Danfo.js is an open source, JavaScript library providing high performance, intuitive, and easy to use data structures for manipulating and processing structured data.
Lean and mean distributed stream processing system written in rust and web assembly. Alternative to Kafka + Flink in one.
A curated list of awesome big data frameworks, ressources and other awesomeness.
A curated list of awesome System Design (A.K.A. Distributed Systems) resources.
A blazingly fast event stream processing library powering the reveald event processing daemon.
Hazelcast is a unified real-time data platform combining stream processing with a fast data store, allowing customers to act instantly on data-in-motion for real-time insights.
Fast, Simple and a cost effective tool to replicate data from Postgres to Data Warehouses, Queues and Storage
A blazingly fast event stream processing library powering the reveald event processing daemon.
Python ETL framework for stream processing, real-time analytics, LLM pipelines, and RAG.
Open-source graph database, tuned for dynamic analytics environments. Easy to adopt, scale and own.
FastStream is a powerful and easy-to-use Python framework for building asynchronous services interacting with event streams such as Apache Kafka, RabbitMQ, NATS and Redis.
📡 MiroTalk WebRTC Live Broadcast allows to broadcast live video, audio and screen stream to all connected users (viewers).
Fast and Lightweight Logs, Metrics and Traces processor for Linux, BSD, OSX and Windows
High-performance, low-footprint SQL database written in C++. Process millions of rows per second from Kafka/Pulsar, Iceberg, or ClickHouse, and seamlessly write results back. Supports powerful feature...
Lean and mean distributed stream processing system written in rust and web assembly. Alternative to Kafka + Flink in one.
Danfo.js is an open source, JavaScript library providing high performance, intuitive, and easy to use data structures for manipulating and processing structured data.
Play any radios around the globe right from the terminal :zap:
Cross-platform, customizable ML solutions for live and streaming media.
Fast, Simple and a cost effective tool to replicate data from Postgres to Data Warehouses, Queues and Storage
Redpanda is a streaming data platform for developers. Kafka API compatible. 10x faster. No ZooKeeper. No JVM!
Cross-platform, customizable ML solutions for live and streaming media.
Python ETL framework for stream processing, real-time analytics, LLM pipelines, and RAG.
FastStream is a powerful and easy-to-use Python framework for building asynchronous services interacting with event streams such as Apache Kafka, RabbitMQ, NATS and Redis.
Redpanda is a streaming data platform for developers. Kafka API compatible. 10x faster. No ZooKeeper. No JVM!
Fast and Lightweight Logs, Metrics and Traces processor for Linux, BSD, OSX and Windows
A curated list of awesome System Design (A.K.A. Distributed Systems) resources.
Lean and mean distributed stream processing system written in rust and web assembly. Alternative to Kafka + Flink in one.
High-performance, low-footprint SQL database written in C++. Process millions of rows per second from Kafka/Pulsar, Iceberg, or ClickHouse, and seamlessly write results back. Supports powerful feature...
A curated list of awesome big data frameworks, ressources and other awesomeness.
Open-source graph database, tuned for dynamic analytics environments. Easy to adopt, scale and own.
Real-time Data Integration and Transformation: use SQL to transform, deliver, and act on fast-changing data.
Fast, Simple and a cost effective tool to replicate data from Postgres to Data Warehouses, Queues and Storage
flink learning blog. http://www.54tianzhisheng.cn/ 含 Flink 入门、概念、原理、实战、性能调优、源码解析等内容。涉及 Flink Connector、Metrics、Library、DataStream API、Table API & SQL 等内容的学习案例，还有 Flink 落地应用的大型项目案例（PVUV、日志存储、百亿数据实时去重、...
Real-time data processing/feature engineering in Python. Tailored for modern AI/ML systems.
Learn the basics of Apache Kafka® from leaders in the Kafka community with these video courses covering the Kafka ecosystem and hands-on exercises.
A blazingly fast event stream processing library powering the reveald event processing daemon.
csp is a high performance reactive stream processing library, written in C++ and Python
🌟 Examples of use cases that utilize Decodable, as well as demos for related open-source projects such as Apache Flink, Debezium, and Postgres.
FastStream is a powerful and easy-to-use Python framework for building asynchronous services interacting with event streams such as Apache Kafka, RabbitMQ, NATS and Redis.
📡 MiroTalk WebRTC Live Broadcast allows to broadcast live video, audio and screen stream to all connected users (viewers).
High-performance, low-footprint SQL database written in C++. Process millions of rows per second from Kafka/Pulsar, Iceberg, or ClickHouse, and seamlessly write results back. Supports powerful feature...
A curated list of awesome Online Analytical Processing databases, frameworks, ressources and other awesomeness.
A library to build streaming applications that consume from and produce to Kafka.
Open-source graph database, tuned for dynamic analytics environments. Easy to adopt, scale and own.
Fast, Simple and a cost effective tool to replicate data from Postgres to Data Warehouses, Queues and Storage
Stream processing using kafka-python to track people (user input images of target) in the wild over multiple video streams.
Lean and mean distributed stream processing system written in rust and web assembly. Alternative to Kafka + Flink in one.
Python ETL framework for stream processing, real-time analytics, LLM pipelines, and RAG.
Cross-platform, customizable ML solutions for live and streaming media.
FastStream is a powerful and easy-to-use Python framework for building asynchronous services interacting with event streams such as Apache Kafka, RabbitMQ, NATS and Redis.
A curated list of awesome System Design (A.K.A. Distributed Systems) resources.
Lean and mean distributed stream processing system written in rust and web assembly. Alternative to Kafka + Flink in one.
Redpanda is a streaming data platform for developers. Kafka API compatible. 10x faster. No ZooKeeper. No JVM!
Fast and Lightweight Logs, Metrics and Traces processor for Linux, BSD, OSX and Windows
Kubernetes-native platform to run massively parallel data/streaming jobs
Fast, Simple and a cost effective tool to replicate data from Postgres to Data Warehouses, Queues and Storage
A curated list of awesome big data frameworks, ressources and other awesomeness.
Open-source graph database, tuned for dynamic analytics environments. Easy to adopt, scale and own.
Self-contained distributed software platform for building stateful, massively real-time streaming applications in Rust.
Python ETL framework for stream processing, real-time analytics, LLM pipelines, and RAG.
csp is a high performance reactive stream processing library, written in C++ and Python
A curated list of awesome Online Analytical Processing databases, frameworks, ressources and other awesomeness.
FastStream is a powerful and easy-to-use Python framework for building asynchronous services interacting with event streams such as Apache Kafka, RabbitMQ, NATS and Redis.
Real-time data processing/feature engineering in Python. Tailored for modern AI/ML systems.
Kubernetes-native platform to run massively parallel data/streaming jobs
🌟 Examples of use cases that utilize Decodable, as well as demos for related open-source projects such as Apache Flink, Debezium, and Postgres.
Built a real-time streaming pipeline to extract stock data, using Apache Nifi, Debezium, Kafka, and Spark Streaming. Loaded the transformed data into Glue database and created real-time dashboards usi...
📡 MiroTalk WebRTC Live Broadcast allows to broadcast live video, audio and screen stream to all connected users (viewers).
Lean and mean distributed stream processing system written in rust and web assembly. Alternative to Kafka + Flink in one.
A blazingly fast event stream processing library powering the reveald event processing daemon.
Fast, Simple and a cost effective tool to replicate data from Postgres to Data Warehouses, Queues and Storage