Search *

15 results

apache/hudi 0.15.0

Upserts, Deletes And Incremental Processing on Big Data.

Scala versions: 2.13 2.12 2.11

stream-processing data-integration apacheflink apachespark incremental-processing hudi bigdata datalake apachehudi

5464 376
gearpump/gearpump 0.9.0

Lightweight real-time big data streaming engine over Akka

Scala versions: 2.12

akka bigdata scala stream-processing

763 26
touk/nussknacker 1.18.0

Low-code tool for automating actions on real time data | Stream processing for the users.

Scala versions: 2.13 2.12

decisioning streaming decision-making low-code big-data automation flink kafka stream-processing scala real-time data-streaming gui decision-engine apache-flink flink-kafka rules-engine lowcode touk

664 65
tomasmikula/libretto 0.3

Declarative concurrency and stream processing library for Scala

Scala versions: 3.x

Scala.js versions: 1.x

functional-programming session-types resource-safety concurrency declarative-programming expressiveness type-safety stream-processing linear-types

200 4
akka/akka-stream-contrib 0.11

Add-ons to Akka Stream

Scala versions: 2.13 2.12

akka akka-streams stream-processing

172 34
streamnative/pulsar-spark 2.4.5

Spark Connector to read and write with Pulsar

Scala versions: 2.11

structured-streaming apache-spark apache-pulsar flink data-science batch-processing stream-processing spark-sql spark data-processing

113 20
banno/kafka4s 6.0.1

Functional programming with Kafka and Scala

Scala versions: 2.13

cats-effect fp kafka stream-processing scala cats fs2 functional-programming

94 20
spinoco/fs2-kafka 0.4.0

Kafka client for functional streams for scala (fs2)

Scala versions: 2.12 2.11

fs2-kafka kafka-driver streaming scodec kafka stream-processing scala asynchronous kafka-client

78 3
gigahexhq/jetprobe 0.1.0

🚀 Validation DSL for data pipelines

Scala versions: 2.12 2.11

bigdata akka scala integration-testing stream-processing akka-actors

24 2
amient/affinity 0.15.2

Library and a Framework for building fast, scalable, fault-tolerant Data APIs based on Akka, Avro, ZooKeeper and Kafka

Scala versions: 2.12

distributed-systems restapi stream-processing high-availability akka-http scalability avro kafka

26 2
anicolaspp/minikaf 1.0.0

Minikaf is a minimal implementation of Publish / Subscriber for in memory communication.

Scala versions: 2.12

reactive kafka stream-processing streams scala reactive-programming

10 1
codefeedr/codefeedr 0.1.10

CodeFeedr core infrastructure

Scala versions: 2.12

flink kafka scala stream-processing sbt

10 3
rtyley/line-break-preserving-line-splitting 0.1.5

Scala versions: 3.x 2.13

jvm splitting-text newline-character-sequences stream-processing io-streams linebreaks

3 1
streamnative/pulsar-flink 1.14.3.4

Elastic data processing with Apache Pulsar and Apache Flink

Scala versions: 2.12 2.11

flink-stream-processing catalog flink data-processing batch-processing sql schema-registry apache-pulsar apache-flink schema stream-processing pulsar flink-connector

278 33
pravega/flink-connectors 0.13.0

Apache Flink connectors for Pravega.

Scala versions: 2.12

flink pravega stream-processing

96 28