Awesome Open Source
Search
Programming Languages
Languages
All Categories
Categories
About
Search results for scala stream
scala
x
stream
x
183 search results found
Zio
⭐
3,978
ZIO — A type-safe, composable library for async and concurrent programming in Scala
Awesome Streaming
⭐
2,447
a curated list of awesome streaming frameworks, applications, etc
Fs2
⭐
2,325
Compositional, streaming I/O library for Scala
Kafka Streams Examples
⭐
2,248
Demo applications and code examples for Apache Kafka's Streams API.
Squbs
⭐
1,381
Akka Streams & Akka HTTP for Large-Scale Production Deployments
Alpakka
⭐
1,259
Alpakka is a Reactive Enterprise Integration library for Java and Scala, based on Reactive Streams and Akka.
Flink Training
⭐
775
Apache Flink Training Excercises
Real_world_scala
⭐
621
an introduction book on real world's scala, including its main stream frameworks and MOMs...
Streamdm
⭐
456
Stream Data Mining Library for Spark Streaming
Akka.js
⭐
456
Akka, for Scala.js
Scala Java8 Compat
⭐
436
A Java 8 compatibility kit for Scala.
Akka Grpc
⭐
427
Akka gRPC
Akka Streams Example
⭐
362
Redis4cats
⭐
325
🔖 Redis client built on top of Cats Effect, Fs2 and Lettuce
Cloudflow
⭐
323
Cloudflow enables users to quickly develop, orchestrate, and operate distributed streaming applications on Kubernetes.
Zio Kafka
⭐
322
A Kafka client for ZIO and ZIO Streams
Scalatest Embedded Kafka
⭐
290
A library that provides an in-memory Kafka instance to run your tests against.
Akka Analytics
⭐
281
Large-scale event processing with Akka Persistence and Apache Spark
Streamz
⭐
269
A combinator library for integrating Functional Streams for Scala (FS2), Akka Streams and Apache Camel
Parquet4s
⭐
267
Read and write Parquet in Scala. Use Scala classes as schema. No need to start a cluster.
Twitter4s
⭐
258
An asynchronous non-blocking Scala client for both the Twitter Rest and Streaming API
Op Rabbit
⭐
237
The Opinionated RabbitMQ Library for Scala and Akka
Azure Event Hubs Spark
⭐
225
Enabling Continuous Data Processing with Apache Spark and Azure Event Hubs
Airstream
⭐
219
State propagation and event streams with mandatory ownership and no glitches
Eventstore.jvm
⭐
217
Event Store JVM Client
Scala Machines
⭐
216
A stream processing library for Scala
Flink Streaming Demo
⭐
209
Kafka With Akka Streams Kafka Streams Tutorial
⭐
191
Code samples for the Lightbend tutorial on writing microservices with Akka Streams, Kafka Streams, and Kafka
Kafka Streams Scala
⭐
191
Thin Scala wrapper around Kafka Streams Java API
Iteratee
⭐
188
Iteratees for Cats
Reactive Rabbit
⭐
185
Reactive Streams driver for AMQP protocol. Powered by RabbitMQ library.
Mockedstreams
⭐
182
Scala DSL for Unit-Testing Processing Topologies in Kafka Streams
Fs2 Aws
⭐
179
fs2 utilities to interact with AWS
Swave
⭐
176
A lightweight Reactive Streams Infrastructure Toolkit for Scala.
Sentinel
⭐
175
Boilerplate for creating reactive TCP clients / servers on Akka Streams
Akka Stream Contrib
⭐
172
Add-ons to Akka Stream
Spark Streaming With Kafka
⭐
161
Self-contained examples of Apache Spark streaming integrated with Apache Kafka.
Kafka Rx
⭐
160
reactive kafka client
Spark Structured Streaming Examples
⭐
153
Spark Structured Streaming / Kafka / Cassandra / Elastic
Circe Fs2
⭐
149
Streaming JSON parsing and decoding with fs2
Fs2 Rabbit
⭐
143
🐰 RabbitMQ stream-based client built on top of Fs2
Kinesis Sql
⭐
135
Kinesis Connector for Structured Streaming
Saxonsoc
⭐
133
SoC based on VexRiscv and ICE40 UP5K
Akka Persistence Inmemory
⭐
131
Akka-persistence-inmemory is a plugin for akka-persistence that stores journal and snapshot messages memory, which is very useful when testing persistent actors, persistent FSM and akka cluster
Akka Stream Extensions
⭐
127
Extensions for Akka Stream
Articles
⭐
126
Code snippets for articles posted at 4comprehension.com
Fs2 Cron
⭐
124
FS2 streams based on cron expressions
Embedded Kafka Schema Registry
⭐
106
A library that provides in-memory instances of both Kafka and Confluent Schema Registry to run your tests against.
Prox
⭐
99
A Scala library for working with system processes
Purefun
⭐
98
Functional Programming library for Java
Spark Streaming Example Project
⭐
95
A Spark Streaming job reading events from Amazon Kinesis and writing event counts to DynamoDB
Fastvdma
⭐
92
Antmicro's fast, vendor-neutral DMA IP in Chisel
Rules
⭐
90
Ant's simple rule engine for Java, Java 8, Scala and Node.js.
Kafkastreams4s
⭐
90
Kafka Streams for Scala. Integrates KafkaStreams with the cats-effect ecosystem
Qstreaming
⭐
89
A simplified, lightweight ETL pipeline framework for build stream/batch processing applications on top of Apache Spark
Reactive Kafka Microservice Template
⭐
84
An example of a microservice template which uses akka/reactive-kafka to stream JSON messages
Akka Streams In Practice
⭐
82
Import data from CSV files to Cassandra using Akka Streams
Play Iteratees Extras
⭐
82
Extra iteratees for Play
Flink Jpmml
⭐
82
flink-jpmml is a fresh-made library for dynamic real time machine learning predictions built on top of PMML standard models and Apache Flink streaming engine
Travesty
⭐
81
Diagram- and graph-generating library for Akka Streams
Zio Sqs
⭐
80
ZIO-powered client for AWS SQS
Reactive Viz
⭐
77
Reactive streams (akka-streams) visualizer
Omnibus
⭐
75
An HTTP-friendly persistent message bus.
Kafka Connect Twitter
⭐
75
Kafka Connect Sink/Source for Twitter
Event Stream Api
⭐
73
Restful Event Stream API built with Free monads
Kafka Streams Query
⭐
71
Library offering http based query on top of Kafka Streams Interactive Queries
Scalaz Netty
⭐
70
A minimalist wrapper for Netty in terms of scalaz-stream
Scala World 2015
⭐
69
Source code for the scala.world 2015 talk about akka-stream / akka-http
Chopsticks
⭐
67
Essential Scala libraries for everyday use
Grpcakkastream
⭐
66
Use GRPC services with the Akka-stream API
Intro To Akka Streams
⭐
65
Streamerz
⭐
63
Playground of Akka Streams and video processing in Scala
Flight_delay_akka_streams
⭐
62
A POC to demonstrate calculating average flight delays using Akka Streams.
Sparse
⭐
62
Generalized, incremental parser combinators for scalaz-stream
Scala Benchmarks
⭐
60
An independent set of benchmarks for testing common Scala idioms.
Coast
⭐
59
Experiments in Streaming
Scalaxy Streams
⭐
57
Scalaxy/Streams: make your Scala collections faster!
Aws Lambda Scala Example Project
⭐
57
An AWS Lambda function in Scala reading events from Amazon Kinesis and writing event counts to DynamoDB
Akka Http Akka Streams Akka Actors Integration
⭐
57
Streaming Chuck Norris jokes in JSON as Server Sent Events using Akka Steams, Akka HTTP and Akka Actors
Freq Count
⭐
55
Lossy Counting and Sticky Sampling implementation for efficient frequency counts on data streams.
Akka Ui
⭐
53
AkkaUI - Build your reactive UI using Akka.js
Spark Cep
⭐
51
Spark CEP is an extension of Spark Streaming to support SQL-based query processing
Akka Stream Apns
⭐
50
Reactive Streams for APNs
Akka Streams Websocket Game Server
⭐
50
Game server and client based on scala, akka streams and websocket
Sse Perf
⭐
49
Load testing for Server Sent Event streams (or other HTTP connections that deliver information in chunks) using Play Framework 2.1 -- this project needs an upgrade to the latest Play version. Anyone interested in submitting a PULL REQUEST?
Ann
⭐
49
Artificial Neural Networks in Akka
Akka Agent
⭐
48
Interop Reactive Streams
⭐
47
Interoperability Layer Between ZIO and Reactive Streams
Nucleus
⭐
47
A lightweight reactive RPC-like system built on Akka IO
Future Streams
⭐
47
Scala Future-based implementation of Reactive Streams
Kafka Streams Scala
⭐
46
Thin Scala wrapper for the Kafka Streams API
Xml Spac
⭐
45
Handle streaming XML and JSON with declarative, composable parsers
Fdp Modelserver
⭐
45
An umbrella project for multiple implementations of model serving
Twitterstream
⭐
45
Twitter Streaming API Example with Kafka Streams in Scala
Scala Conduits
⭐
45
A port to Scala of the Conduit library by Michael Snoyman
Datastax Spark Streaming Demo
⭐
43
Counting Twitter hashtags using Spark Streaming and Cassandra
Strymonas Scala
⭐
43
Fast streams for Scala 3
Trembita
⭐
43
Model complex data transformation pipelines easily
Kafka Scala Examples
⭐
42
Examples of Avro, Kafka, Schema Registry, Kafka Streams, Interactive Queries, KSQL, Kafka Connect in Scala
Snowplow S3 Loader
⭐
41
Mirrors a Kinesis stream to Amazon S3 using the KCL
Related Searches
Javascript Stream (6,703)
Scala Sbt (4,178)
Scala Spark (3,279)
Python Stream (2,326)
Java Stream (2,181)
Scala Akka (2,120)
Java Scala (1,794)
Stream Streaming (1,713)
Scala Play Framework (1,309)
Plugin Scala (1,079)
1-100 of 183 search results
Next >
Privacy
|
About
|
Terms
|
Follow Us On Twitter
Copyright 2018-2024 Awesome Open Source. All rights reserved.