Lightweight real-time big data streaming engine over Akka
Upserts, Deletes And Incremental Processing on Big Data.
A visual tool to define and run real-time decision algorithms. Brings agility to business teams, liberates developers to focus on technology.
Add-ons to Akka Stream
Declarative concurrency and stream processing library for Scala
When Apache Pulsar meets Apache Spark
Kafka client for functional streams for scala (fs2)
Functional programming with Kafka and Scala
🚀 Validation DSL for data pipelines
Library and a Framework for building fast, scalable, fault-tolerant Data APIs based on Akka, Avro, ZooKeeper and Kafka
Minikaf is a minimal implementation of Publish / Subscriber for in memory communication.
CodeFeedr core infrastructure
Apache Flink connectors for Pravega.
Elastic data processing with Apache Pulsar and Apache Flink