Upserts, Deletes And Incremental Processing on Big Data.
Lightweight real-time big data streaming engine over Akka
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
Elastic data processing with Apache Pulsar and Apache Flink
Apache Flink connectors for Pravega.