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