16 projects
Apache Flink
Apache Flink is a distributed stream processing and batch computation framework. It provides high-throughput, low-latency data streaming engines as well as support for event-driven applications and batch processing. The framework enables stateful computations over data streams and features automatic memory management, fault tolerance, and exactly-once processing semantics.
4,830
564
$97M
Apache Kafka
Apache Kafka is a distributed event streaming platform designed for high-throughput, fault-tolerant handling of real-time data feeds. It enables building real-time streaming data pipelines and applications that can process, transform, and react to streams of events.
4,157
710
$43M
Strimzi
Strimzi provides a way to run an Apache Kafka cluster on Kubernetes in various deployment configurations.
3,531
834
$122M
Apache Pulsar
Apache Pulsar is a cloud-native, distributed messaging and streaming platform designed to handle high-performance workloads. It provides pub-sub messaging, queuing, stream processing, and event streaming capabilities with built-in multi-tenancy, geo-replication, and persistent storage features.
3,483
530
$28M
Pravega
Pravega is a storage system that uses Stream as the main building block for storing continuous and limitless data.
775
165
$70M
Tremor
Tremor is an early stage event processing system for unstructured data with rich support for structural pattern matching, filtering and transformation.
478
92
$11M
Apache Kafka client for Go
Sarama is a Go library for Apache Kafka.
AutoMQ
AutoMQ is a cloud-native alternative to Kafka by decoupling durability to S3 and EBS. 10x Cost-Effective. No Cross-AZ Traffic Cost. Autoscale in seconds. Single-digit ms latency.
BookKeeper
Apache BookKeeper - a scalable, fault tolerant and low latency storage service optimized for append-only workloads
Celeborn
Apache Celeborn is an elastic and high-performance service for shuffle and spilled data.
Franz
franz-go contains a feature complete, pure Go library for interacting with Kafka from 0.8.0 through 3.8+. Producing, consuming, transacting, administrating, etc.
Kafka Docker Playground
🐳✨ Fully automated Apache Kafka® and Confluent Docker based examples // 👷♂️ Easily build examples or reproduction models
Redpanda
Redpanda is a streaming data platform for developers. Kafka API compatible. 10x faster. No ZooKeeper. No JVM!
RocketMQ
Apache RocketMQ is a cloud native messaging and streaming platform, making it simple to build event-driven applications.
Storm
Apache Storm
Viridian
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.