15 results
-
apache/hudi
Upserts, Deletes And Incremental Processing on Big Data.
Scala versions: 2.12 2.11 -
touk/nussknacker
Low-code tool for automating actions on real time data | Stream processing for the users.
Scala versions: 2.13 2.12 2.11 -
tomasmikula/libretto
Declarative concurrency and stream processing library for Scala
Scala versions: 3.x -
akka/akka-stream-contrib
Add-ons to Akka Stream
Scala versions: 2.13 2.12 2.11 -
streamnative/pulsar-spark
Spark Connector to read and write with Pulsar
Scala versions: 2.13 2.12 2.11 -
banno/kafka4s
Functional programming with Kafka and Scala
Scala versions: 2.13 2.12 -
spinoco/fs2-kafka
Kafka client for functional streams for scala (fs2)
Scala versions: 2.12 2.11 -
gigahexhq/jetprobe
🚀 Validation DSL for data pipelines
Scala versions: 2.12 2.11 -
amient/affinity
Library and a Framework for building fast, scalable, fault-tolerant Data APIs based on Akka, Avro, ZooKeeper and Kafka
Scala versions: 2.12 2.11 -
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: 3.x 2.13 -
pravega/flink-connectors
Apache Flink connectors for Pravega.
Scala versions: 2.12 2.11 -
streamnative/pulsar-flink
Elastic data processing with Apache Pulsar and Apache Flink
Scala versions: 2.12 2.11