Event streaming platform for agentic AI. Continuously ingest, transform, and serve event streams in real time, at scale.
Repository Index
47,133 repositories indexed
1–24 of 27 · Most stars
Fancy stream processing made operationally mundane
- message-queue
- stream-processing
- streaming-data
- message-bus
Apache KIE (Knowledge Is Everything) is the home of Drools, OptaPlanner, jBPM, and Kogito.
- rule-engine
- java
- dmn
- hacktoberfest
🦀 event stream processing for developers to collect and transform data in motion to power responsive data intensive applications.
- cloud-native
- streaming
- rust
- real-time
Distributed stream processing engine in Rust
A network event stream processing system, in Clojure.
- riemann
- events
- clojure
- monitoring
The fastest unified streaming SQL Engine in a single C++ binary. ⚡ Millisecond latency. 100+ GB/s throughput. Continuously compute stateful context from streams, logs, metrics, events, and CDC.
- clickhouse
- kakfa
- sql
- redpanda
Python Stream Processing
- python
- stream-processing
- rust
- data-engineering
Lightweight data stream processing engine for IoT edge
Stream Processing and Complex Event Processing Engine
- streaming-data-processing
- cep
- stream-processing
- complex-event-processing
Python Streaming DataFrames for Kafka
Distributed Stream Processing
- stream-processing
- stream-processor
- stream-processing-engine
- pony-language
High performance Rust stream processing engine seamlessly integrates AI capabilities, providing powerful real-time data processing and intelligent analysis.
- flow
- rust
- rust-lang
- stream
🌊 Continuously synchronize the systems where your data lives, to the systems where you _want_ it to live, by managing your data flows with Estuary. 🌊
- change-data-capture
- data
- data-collection
- data-engineering
Tenzir is the data pipeline engine for security teams.
- incident-response
- threathunting
- siem
- soc
Lightweight real-time big data streaming engine over Apache Pekko
- akka
- stream-processing
- bigdata
- scala
Low-code tool for automating actions on real time data | Stream processing for the users.
- flink
- flink-kafka
- apache-flink
- gui
Conduit streams data between data stores. Kafka Connect replacement. No JVM required.
- go
- data-integration
- etl
- data-pipeline
A streaming / online query processing / analytics engine based on Apache Storm
Lightweight stream processing engine for IoT
Machine is a workflow/pipeline library for processing data
- golang
- golang-library
- golang-package
- workflow
Multi-core Window-Based Stream Processing Engine
- llvm
- incremental-computation
- aggregation
- stream-processing
Lightweight SQL-based stream processing engine for IoT edge.
Open-source streaming SQL engine written in Rust using Apache Arrow and DataFusion. Supports continuous queries, temporal stream joins, tumbling/session windows, and CDC/Kafka connectors. Lightweight, embeddable, and sub-microsecond latency