Upserts, Deletes And Incremental Processing on Big Data.
Lightweight real-time big data streaming engine over Akka
Add-ons to Akka Stream
Kafka client for functional streams for scala (fs2)
Functional programming with Kafka and Scala
Apache Flink connectors for Pravega.
Library and a Framework for building fast, scalable, fault-tolerant Data APIs based on Akka, Avro, ZooKeeper and Kafka
🚀 Validation DSL for data pipelines
CodeFeedr core infrastructure