dagger
Stream processor
A cloud-native framework for stateful processing of real-time streaming data
Dagger is an easy-to-use, configuration over code, cloud-native framework built on top of Apache Flink for stateful processing of real-time streaming data.
268 stars
15 watching
41 forks
Language: Java
last commit: about 3 years agoLinked from 1 awesome list
apache-flinkapache-kafkadataopsframeworkinfluxdbprometheusreal-time-analyticsreal-time-processingstream-processing
dharmeshkakadia/awesome-kafkaRelated projects:
| Repository | Description | Stars |
|---|---|---|
 lsds/saber | A hybrid stream processing engine designed to optimize data processing on heterogeneous architectures. | 38 |
 jpcik/morph-streams | A tool for processing and analyzing continuous data streams using query languages | 16 |
 olacabs/fabric | A real-time stream processing framework designed to handle high-volume event ingestion and complex data processing tasks with guaranteed availability and scalability. | 55 |
 knowledgeonwebscale/streamingmassif | A Java-based platform for efficient processing of data streams by performing cascading reasoning and complex event processing. | 10 |
 bkirwi/coast | A streaming data processing framework with strong ordering and exactly-once semantics | 60 |
 confluentinc/ksql | A database for real-time stream processing applications built on top of Apache Kafka. | 133 |
 streampunk/beamcoder | Provides Node.js bindings to FFmpeg for media processing and manipulation | 401 |
 apache/rocketmq-streams | Provides a lightweight stream processing framework | 172 |
| lsds/lightsaber | A high-throughput stream processing engine designed for multi-core CPUs with support for incremental computation and fault-tolerance semantics. | 70 |
 streamthoughts/kafka-connect-file-pulse | A tool that enables streaming and processing of various file formats into Apache Kafka | 324 |
| raystack/firehose | Delivers real-time streaming data to various destinations | 329 |
 scramjetorg/framework-js | A reactive stream programming framework that enables concurrent execution of asynchronous operations on data streams. | 38 |
 gojek/ziggurat | A framework for building stateless applications on top of Kafka stream processing | 399 |
 hortonworks/streamline | A toolset for building and deploying real-time data processing applications using various streaming engines and frameworks. | 165 |
| raystack/raccoon | A high-throughput service for collecting and publishing event data in real-time from various sources using multiple network protocols. | 200 |