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)
When Apache Pulsar meets Apache Spark
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