Fancy stream processing made operationally mundane
- message-queue
- stream-processing
- streaming-data
- message-bus
47,133 repositories indexed
1–10 of 10 · Most stars
Fancy stream processing made operationally mundane
The live data layer for apps and AI agents. Create up-to-the-second views into your business, just using SQL
Where data access meets operational intelligence
KubeBlocks is a Kubernetes Operator designed to manage a variety of databases and streaming systems, including MySQL, PostgreSQL, MongoDB, Redis, RabbitMQ, RocketMQ, and more, within Kubernetes environments.
Job Scheduler for IOS with Concurrent run, failure/retry, persistence, repeat, delay and more
A pipe-like function to verticalize your JavaScript code
Sento - Actor framework featuring actors and agents for easy access to state and asynchronous operations.
General-purpose, formally-verified, 64-bit operating system in SPARK/Ada for x86-64
Stateful actors on Apache Flink 2.x and Java 21 — durable per-key state, exactly-once messaging, Kafka and Kinesis I/O, Kubernetes-native deployment. Continues the Apache Stateful Functions programming model on the modern Flink line.
Conflict-free merge for DataFrames, JSON, ML models & distributed agents — powered by CRDTs. The first merge library where every operation is mathematically guaranteed to converge.