🦀 event stream processing for developers to collect and transform data in motion to power responsive data intensive applications.

rust distributed-systems streaming real-time serverless webassembly data-flow stream-processing data-analytics data-integration cloud-native data-pipelines stateful streaming-data stream-processing-engine event-driven-architecture streaming-analytics streaming-data-processing streaming-data-pipelines

• Updated Nov 5, 2026
• Rust

Distributed stream processing engine in Rust

infrastructure rust data sql kafka stream-processing stream-processing-engine dev-tools data-stream-processing

• Updated Nov 12, 2026
• Rust

Distributed Stream Processing

python go linux api golang framework stream-processing pony-language stream-processing-engine stream-processor

• Updated Sep 3, 2026
• Pony

Streaming System 相关的论文读物

streaming apache-spark storm stream-processing spark-streaming dataflow flink heron drizzle millwheel s4 streaming-engine spe stream-processing-engine

• Updated Feb 12, 2022

Grid Solutions Framework

time-series libraries electric stream-processing complex-event-processing gsf communications synchrophasor comtrade ieee-c37118 ieee-1344 macrodyne streaming-data pqdif stream-processing-engine osi-pi pmu phasor-measurement-unit

• Updated Nov 3, 2026
• C#

Open Source Phasor Data Concentrator

hadoop time-series stream-processing complex-event-processing synchrophasor ieee-c37118 ieee-1344 streaming-data iec61850 stream-processing-engine phasor-data-concentrator openpdc pdc bpa-pdc-stream naspi pmu phasor-measurement-unit

• Updated Nov 11, 2026
• C#

A High-performance Cluster Computing Engine

distributed-systems streaming parallel-computing reactor event-driven-programming dataflow-programming network-programming stream-processing-engine cluster-computing

• Updated May 4, 2019
• C++

Rust-native, pattern-first stream processing engine (CEP): filters, joins, enrichment, windows—low latency on-prem & Kubernetes.

infrastructure rust events data sql cep stream-processing complex-event-processing stream-processing-engine data-stream-processing

• Updated Nov 8, 2026
• Rust

An event stream processor anyone can use

log-analysis event-stream cep stream-processing beepbeep stream-processing-engine

• Updated Apr 21, 2026
• Java

A streaming real-time event processor based on Riemann written in Node.js -- Streams2/3 edition

nodejs streaming statistics reactive analytics websockets realtime event-sourcing streams stream-processing server-sent-events riemann eventsourcing event-processing streams2 stream-processing-engine stream-processor event-processor streams3 push-streams

• Updated Nov 29, 2016
• CoffeeScript

An HTTP dashboard for Godot2.

nodejs streaming statistics reactive dashboard analytics websockets realtime event-sourcing streams stream-processing server-sent-events riemann eventsourcing event-processing stream-processing-engine stream-processor event-processor streams3 push-streams

• Updated Nov 29, 2016
• JavaScript

A lightweight, command-line data-stream processing framework written in Rust

stream-processing event-processing stream-processing-engine

• Updated May 7, 2026
• Rust

Anti-Cheat Detection for Game Streaming

game screenshot gamedev streaming games gaming game-engine fps game-development stream-processing screenshot-library faceit stream-processing-engine first-person-shooter game-dev smac cheating-script first-person-activity-recognition game-streaming

• Updated Aug 3, 2019

Stateful stream processing for your OTEL observability pipelines.

rust observability stream-processing-engine opentelemetry

• Updated Oct 29, 2026
• Rust

Stream Processing Abstraction Framework for Java.

kafka apache-spark rabbitmq stream-processing apache-storm apache-flink stream-processing-engine apache-samza stream-processing-software

• Updated Apr 18, 2023
• Java

Complex event processing engine for IR4 workloads

kafka cloud-native complex-event-processing rules-engine stream-processing-engine azure-pipelines

• Updated Mar 27, 2020
• Java

A Rust service designed to receive media (audio, image, and video) via gRPC streaming, process the content in chunks with constant memory usage O(1), and publish processing progress. The project serves as the foundational infrastructure for media storage and ingestion within the SX ecosystem.

rust etl async high-performance clean-architecture stream-processing tokio high-performance-computing asynchronous-programming hexagonal-architecture tokio-rs stream-processing-engine etl-pipeline etl-automation etl-process etl-pipelines stream-processing-software high-performance-computing-engineering

• Updated Aug 4, 2026
• Rust

Continuous Query Engine for the Detection of Anomalous ATM transactions

property-graph stream-processing-engine continuous-query-evaluation dynamic-pipeline atm-transactions

• Updated Mar 23, 2025
• Python

The Unified Data Ingestion System is designed to handle both streaming and batch data ingestion with a modular architecture.

kafka batch-processing stream-processing-engine data-ingestion

• Updated May 5, 2025
• Python

Stream processing in Rust with a Flink-inspired DataStream API and runnable benchmark workloads.

rust benchmarking data-stream stream-processing data-engineering apache-flink stream-processing-engine nexmark event-time

• Updated Nov 12, 2026
• Rust