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