spinoco/fs2-mail   0.2.0

asynchronous library for sending and receiving mail via fs2._

absaoss/hyperdrive   4.7.0

Extensible streaming ingestion pipeline on top of Apache Spark

apache/pekko-grpc   1.1.1

Apache Pekko gRPC

fsanaulla/chronicler-spark   0.6.0

InfluxDB connector to Apache Spark on top of Chronicler

spekka/spekka   0.1.1

Streaming Productivity Enhancements for Akka

zio/zio-ftp   0.4.3

A simple, idiomatic (S)FTP client for ZIO

yannick-cw/elastic-indexer4s   0.6.5

Stream your stuff into elasticsearch

qubole/streaminglens   0.5.3

Qubole Streaminglens tool for tuning Spark Structured Streaming Pipelines

qubole/s3-sqs-connector   0.5.1

A library for reading data from Amzon S3 with optimised listing using Amazon SQS using Spark SQL Streaming ( or Structured streaming).

reactivemongo/reactivemongo-streaming   1.0.10

:leaves: Streaming libraries for ReactiveMongo

qubole/spark-state-store   1.0.0

Rocksdb state storage implementation for Structured Streaming.

d2a4u/sqs4s   1.5.0

Streaming client for AWS SQS using fs2

exasol/spark-connector   1.1.0

A connector for Apache Spark to access Exasol

bdoepf/spark-cassandra-sink   2.4.0

spark-cassandra-sink is a Spark Structured Streaming Sink for cassandra

ozancicek/artan   0.5.1

Online latent state estimation with Spark

lhns/fs2-pcap   0.1.0

A library for capturing, crafting, and sending packets with fs2 using pcap4j

assist-iot-sripas/scala-mqtt-wrapper   4.0.0

Scala wrapper for the Pekko Connectors MQTT Streaming library and the Alpakka MQTT Streaming library.

voidcontext/ghyll   0.1.0

ghyll is a streaming JSON decoder library for Scala

apache/seatunnel   1.5.1

SeaTunnel is a next-generation super high-performance, distributed, massive data integration tool.

theinnerlight/streaming-kafka   0.8.0

FS2-derived streaming kafka library