All tags
Catalogue tag

#stream-processing

Every repository in the public record carrying this tag — from its GitHub topics or the keywords its package registries publish. Health is measured under the same versioned methodology as the rest of the record.

25 records
Tagged “stream-processing”Ranked by health index
crates.io · Maven · npm +1
100Exceptionalhealth index
risingwavelabs/risingwave
Event streaming platform for agentic AI. Continuously ingest, transform, and serve event streams in real time, at scale.
Rust★ 9,302Sep 6, 2026
Apache-2.0Sep 6, 2026 · metrics 2.10.0
PyPI
99Exceptionalhealth index
ag2ai/faststream
FastStream is an asynchronous Python framework for building event-driven applications. It brings together message broker integration, dependency injection, validation, testing utilities, and AsyncAPI documentation generation in a single toolkit
Python★ 5,296↓ 1.4M/moAug 8, 2026
Apache-2.0Aug 8, 2026 · metrics 2.10.0
PyPI · crates.io
97Exceptionalhealth index
online-ml/river
🌊 Online machine learning in Python
Python★ 5,914Aug 12, 2026
BSD-3-ClauseAug 12, 2026 · metrics 2.10.0
crates.io · npm
97Exceptionalhealth index
vectordotdev/vector
A high-performance observability data pipeline.
Rust · CUE★ 22.3K↓ 102/moAug 5, 2026
MPL-2.0Aug 5, 2026 · metrics 2.10.0
npm · Go · crates.io
96Exceptionalhealth index
numaproj/numaflow
Kubernetes-native platform to run massively parallel data/streaming jobs
Rust · Go · TypeScript★ 2,827↓ 38/moSep 2, 2026
Apache-2.0Sep 2, 2026 · metrics 2.10.0
Go · crates.io · npm
95Exceptionalhealth index
PeerDB-io/peerdb
Fast, Simple and a cost effective tool to replicate data from Postgres to Data Warehouses, Queues and Storage
Go · TypeScript★ 3,209Jul 19, 2026
AGPL-3.0Jul 19, 2026 · metrics 2.10.0
Go
95Exceptionalhealth index
redpanda-data/connect
Fancy stream processing made operationally mundane
Go★ 8,737Aug 28, 2026
Custom licenseAug 28, 2026 · metrics 2.10.0
PyPI · crates.io
93Exceptionalhealth index
getsentry/arroyo
A library to build streaming applications that consume from and produce to Kafka.
Python · Rust★ 62↓ 48K/moJul 17, 2026
Apache-2.0Jul 17, 2026 · metrics 2.10.0
Maven
93Exceptionalhealth index
hazelcast/hazelcast
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.
Java★ 6,601Aug 22, 2026
Custom licenseAug 22, 2026 · metrics 2.10.0
PyPI
90Excellenthealth index
Point72/csp
csp is a high performance reactive stream processing library, written in C++ and Python
Python · C++★ 423Jul 18, 2026
Apache-2.0Jul 18, 2026 · metrics 2.10.0
Maven · npm
90Excellenthealth index
spring-cloud/spring-cloud-stream
Framework for building Event-Driven Microservices
Java★ 1,069Jul 26, 2026
Apache-2.0Jul 26, 2026 · metrics 2.10.0
npm · PyPI
88Excellenthealth index
google-ai-edge/mediapipe
Cross-platform, customizable ML solutions for live and streaming media.
C++★ 36.5KAug 5, 2026
Apache-2.0Aug 5, 2026 · metrics 2.10.0
npm
88Excellenthealth index
hazelcast/hazelcast-nodejs-client
Hazelcast Node.js Client
TypeScript · JavaScript★ 152↓ 25.5K/moAug 28, 2026
Apache-2.0Aug 28, 2026 · metrics 2.10.0
Packagist
84Excellenthealth index
sanmai/pipeline
Build streaming pipelines in PHP. The missing pipe operator. General-purpose collections pipeline. Since 2017.
PHP★ 75↓ 1.1M/moJul 22, 2026
Apache-2.0Jul 22, 2026 · metrics 2.10.0
crates.io
83Excellenthealth index
p2panda/p2panda
All the things a panda needs
Rust★ 514↓ 1,283/moJul 18, 2026
Custom licenseJul 18, 2026 · metrics 2.10.0
crates.io
71Goodhealth index
SeaQL/sea-streamer
🌊 Stream processing toolkit for Redis & Kafka
Rust★ 369↓ 51.9K/moAug 8, 2026
Apache-2.0Aug 8, 2026 · metrics 2.10.0
Maven
69Goodhealth index
eschizoid/kpipe
Composable Kafka consumer library for building modular, testable JVM data pipelines.
Java★ 57Jul 24, 2026
Apache-2.0Jul 24, 2026 · metrics 2.10.0
Go
60Moderatehealth index
classmesh/classmesh
Confidence-gated classification cascade in Go: deterministic rules first, models next, expensive calls only for what is left
Go★ 0Jul 17, 2026
MITJul 17, 2026 · metrics 2.10.0
Go
60Moderatehealth index
gloo-foo/framework
Fluent shell pipes for Go — the Unix pipeline model as type-safe, composable Go values
Go★ 1Jul 20, 2026
MITJul 20, 2026 · metrics 2.10.0
crates.io · npm · PyPI
59Moderatehealth index
RedisGears/RedisGears
Dynamic execution framework for your Redis data
Rust · Python · C★ 384Jul 21, 2026
Custom licenseJul 21, 2026 · metrics 2.10.0
Packagist
50Moderatehealth index
halaxa/json-machine
Efficient, easy-to-use, and fast PHP JSON stream parser
PHP★ 1,324↓ 1M/moAug 13, 2026
Apache-2.0Aug 13, 2026 · metrics 2.10.0
Maven
39Weakhealth index
zhisheng17/flink-learning
flink learning blog. http://www.54tianzhisheng.cn/ 含 Flink 入门、概念、原理、实战、性能调优、源码解析等内容。涉及 Flink Connector、Metrics、Library、DataStream API、Table API & SQL 等内容的学习案例，还有 Flink 落地应用的大型项目案例（PVUV、日志存储、百亿数据实时去重、监控告警）分享。欢迎大家支持我的专栏《大数据实时计算引擎 Flink 实战与性能优化》
Java★ 15.1KAug 5, 2026
Apache-2.0Aug 5, 2026 · metrics 2.10.0
Go · PyPI
34At Riskhealth index
redpanda-data/redpanda
Redpanda is a streaming data platform for developers. Kafka API compatible. 10x faster. No ZooKeeper. No JVM!
C++ · Python★ 12.5KAug 27, 2026
Custom licenseAug 27, 2026 · metrics 2.10.0
Hex
28At Riskhealth index
am-kantox/lazy_for
Lazy implementation of `Kernel.SpecialForms.for/1` based on streams
Elixir★ 3Jul 18, 2026
MITJul 18, 2026 · metrics 2.10.0