Upserts, Deletes And Incremental Processing on Big Data.
Lightweight real-time big data streaming engine over Akka
Add-ons to Akka Stream
Elastic data processing with Apache Pulsar and Apache Flink
Kafka client for functional streams for scala (fs2)
Declarative concurrency and stream processing library for Scala
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