Awesome Open Source
Search results for scala stream
472 search results found
ZIO — A type-safe, composable library for async and concurrent programming in Scala
a curated list of awesome streaming frameworks, applications, etc
Compositional, streaming I/O library for Scala
Kafka Streams Examples
Demo applications and code examples for Apache Kafka's Streams API.
Alpakka Kafka connector - Alpakka is a Reactive Enterprise Integration library for Java and Scala, based on Reactive Streams and Akka.
Akka Streams & Akka HTTP for Large-Scale Production Deployments
Alpakka is a Reactive Enterprise Integration library for Java and Scala, based on Reactive Streams and Akka.
Apache Flink Training Excercises
an introduction book on real world's scala, including its main stream frameworks and MOMs...
Akka, for Scala.js
Stream Data Mining Library for Spark Streaming
Scala Java8 Compat
A Java 8 compatibility kit for Scala.
Akka Streams Example
Cloudflow enables users to quickly develop, orchestrate, and operate distributed streaming applications on Kubernetes.
A Kafka client for ZIO and ZIO Streams
🔖 Redis client built on top of Cats Effect, Fs2 and Lettuce
Scalatest Embedded Kafka
A library that provides an in-memory Kafka instance to run your tests against.
Large-scale event processing with Akka Persistence and Apache Spark
A combinator library for integrating Functional Streams for Scala (FS2), Akka Streams and Apache Camel
An asynchronous non-blocking Scala client for both the Twitter Rest and Streaming API
Read and write Parquet in Scala. Use Scala classes as schema. No need to start a cluster.
The Opinionated RabbitMQ Library for Scala and Akka
Azure Event Hubs Spark
Enabling Continuous Data Processing with Apache Spark and Azure Event Hubs
Event Store JVM Client
A stream processing library for Scala
Flink Streaming Demo
Kafka With Akka Streams Kafka Streams Tutorial
Code samples for the Lightbend tutorial on writing microservices with Akka Streams, Kafka Streams, and Kafka
Kafka Streams Scala
Thin Scala wrapper around Kafka Streams Java API
State propagation and event streams with mandatory ownership and no glitches
Iteratees for Cats
Reactive Streams driver for AMQP protocol. Powered by RabbitMQ library.
Scala DSL for Unit-Testing Processing Topologies in Kafka Streams
A Dynamically Typed Scala Json Library
A lightweight Reactive Streams Infrastructure Toolkit for Scala.
Boilerplate for creating reactive TCP clients / servers on Akka Streams
Akka Stream Contrib
Add-ons to Akka Stream
fs2 utilities to interact with AWS
Spark Streaming With Kafka
Self-contained examples of Apache Spark streaming integrated with Apache Kafka.
reactive kafka client
Spark Structured Streaming Examples
Spark Structured Streaming / Kafka / Cassandra / Elastic
Streaming JSON parsing and decoding with fs2
🐰 RabbitMQ stream-based client built on top of Fs2
Kinesis Connector for Structured Streaming
Akka Persistence Inmemory
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
Extensions for Akka Stream
Code snippets for articles posted at 4comprehension.com
SoC based on VexRiscv and ICE40 UP5K
FS2 streams based on cron expressions
A Scala library for working with system processes
Embedded Kafka Schema Registry
A library that provides in-memory instances of both Kafka and Confluent Schema Registry to run your tests against.
Spark Streaming Example Project
A Spark Streaming job reading events from Amazon Kinesis and writing event counts to DynamoDB
Kafka Streams for Scala. Integrates KafkaStreams with the cats-effect ecosystem
Ant's simple rule engine for Java, Java 8, Scala and Node.js.
A simplified, lightweight ETL pipeline framework for build stream/batch processing applications on top of Apache Spark
Functional Programming library for Java
Reactive Kafka Microservice Template
An example of a microservice template which uses akka/reactive-kafka to stream JSON messages
Akka Streams In Practice
Import data from CSV files to Cassandra using Akka Streams
Play Iteratees Extras
Extra iteratees for Play
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
Diagram- and graph-generating library for Akka Streams
Antmicro's fast, vendor-neutral DMA IP in Chisel
Reactive streams (akka-streams) visualizer
An HTTP-friendly persistent message bus.
ZIO-powered client for AWS SQS
Kafka Connect Twitter
Kafka Connect Sink/Source for Twitter
Event Stream Api
Restful Event Stream API built with Free monads
Kafka Streams Query
Library offering http based query on top of Kafka Streams Interactive Queries
A minimalist wrapper for Netty in terms of scalaz-stream
Scala World 2015
Source code for the scala.world 2015 talk about akka-stream / akka-http
Essential Scala libraries for everyday use
Use GRPC services with the Akka-stream API
Intro To Akka Streams
Playground of Akka Streams and video processing in Scala
A POC to demonstrate calculating average flight delays using Akka Streams.
Generalized, incremental parser combinators for scalaz-stream
An independent set of benchmarks for testing common Scala idioms.
Experiments in Streaming
Aws Lambda Scala Example Project
An AWS Lambda function in Scala reading events from Amazon Kinesis and writing event counts to DynamoDB
Akka Http Akka Streams Akka Actors Integration
Streaming Chuck Norris jokes in JSON as Server Sent Events using Akka Steams, Akka HTTP and Akka Actors
Scalaxy/Streams: make your Scala collections faster!
Lossy Counting and Sticky Sampling implementation for efficient frequency counts on data streams.
AkkaUI - Build your reactive UI using Akka.js
Spark CEP is an extension of Spark Streaming to support SQL-based query processing
Akka Streams Websocket Game Server
Game server and client based on scala, akka streams and websocket
Akka Stream Apns
Reactive Streams for APNs
Artificial Neural Networks in Akka
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?
A lightweight reactive RPC-like system built on Akka IO
Scala Future-based implementation of Reactive Streams
Kafka Streams Scala
Thin Scala wrapper for the Kafka Streams API
A port to Scala of the Conduit library by Michael Snoyman
Twitter Streaming API Example with Kafka Streams in Scala
An umbrella project for multiple implementations of model serving
Interop Reactive Streams
Interoperability Layer Between ZIO and Reactive Streams
Fast streams for Scala 3
Model complex data transformation pipelines easily
Datastax Spark Streaming Demo
Counting Twitter hashtags using Spark Streaming and Cassandra
Kafka Scala Examples
Examples of Avro, Kafka, Schema Registry, Kafka Streams, Interactive Queries, KSQL, Kafka Connect in Scala
Scala Sbt (4,178)
Scala Spark (3,279)
Python Stream (2,326)
Java Stream (2,181)
Scala Akka (2,117)
Java Scala (1,794)
Stream Streaming (1,696)
Scala Play Framework (1,309)
Plugin Scala (1,080)
1-100 of 472 search results
Follow Us On Twitter
Copyright 2018-2023 Awesome Open Source. All rights reserved.