15 results
-
apache/hudi
Upserts, Deletes And Incremental Processing on Big Data.
Scala versions: 2.11 2.12 -
touk/nussknacker
A visual tool to define and run real-time decision algorithms. Brings agility to business teams, liberates developers to focus on technology.
Scala versions: 2.11 2.12 -
akka/akka-stream-contrib
Add-ons to Akka Stream
Scala versions: 2.11 2.12 2.13 -
tomasmikula/libretto
Declarative concurrency and stream processing library for Scala
Scala versions: 3.x -
streamnative/pulsar-spark
When Apache Pulsar meets Apache Spark
Scala versions: 2.11 2.12 -
spinoco/fs2-kafka
Kafka client for functional streams for scala (fs2)
Scala versions: 2.11 2.12 -
banno/kafka4s
Functional programming with Kafka and Scala
Scala versions: 2.12 2.13 -
gigahexhq/jetprobe
🚀 Validation DSL for data pipelines
Scala versions: 2.11 2.12 -
amient/affinity
Library and a Framework for building fast, scalable, fault-tolerant Data APIs based on Akka, Avro, ZooKeeper and Kafka
Scala versions: 2.11 2.12 -
anicolaspp/minikaf
Minikaf is a minimal implementation of Publish / Subscriber for in memory communication.
Scala versions: 2.12 -
rtyley/line-break-preserving-line-splitting
Scala versions: 2.13 3.x -
streamnative/pulsar-flink
Elastic data processing with Apache Pulsar and Apache Flink
Scala versions: 2.11 2.12