Awesome Open Source

Programming Languages

Search results for scala stream

472 search results found

ZIO — A type-safe, composable library for async and concurrent programming in Scala

Awesome Streaming ⭐ 2,303

a curated list of awesome streaming frameworks, applications, etc

Compositional, streaming I/O library for Scala

Kafka Streams Examples ⭐ 2,162

Demo applications and code examples for Apache Kafka's Streams API.

Alpakka Kafka ⭐ 1,404

Alpakka Kafka connector - Alpakka is a Reactive Enterprise Integration library for Java and Scala, based on Reactive Streams and Akka.

Squbs ⭐ 1,381

Akka Streams & Akka HTTP for Large-Scale Production Deployments

Alpakka ⭐ 1,252

Alpakka is a Reactive Enterprise Integration library for Java and Scala, based on Reactive Streams and Akka.

Flink Training ⭐ 646

Apache Flink Training Excercises

Real_world_scala ⭐ 621

an introduction book on real world's scala, including its main stream frameworks and MOMs...

Akka.js ⭐ 456

Akka, for Scala.js

Streamdm ⭐ 456

Stream Data Mining Library for Spark Streaming

Scala Java8 Compat ⭐ 436

A Java 8 compatibility kit for Scala.

Akka Grpc ⭐ 424

Akka Streams Example ⭐ 362

Cloudflow ⭐ 323

Cloudflow enables users to quickly develop, orchestrate, and operate distributed streaming applications on Kubernetes.

Zio Kafka ⭐ 307

A Kafka client for ZIO and ZIO Streams

Redis4cats ⭐ 299

🔖 Redis client built on top of Cats Effect, Fs2 and Lettuce

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

Twitter4s ⭐ 258

An asynchronous non-blocking Scala client for both the Twitter Rest and Streaming API

Parquet4s ⭐ 242

Read and write Parquet in Scala. Use Scala classes as schema. No need to start a cluster.

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

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

Airstream ⭐ 188

State propagation and event streams with mandatory ownership and no glitches

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

A Dynamically Typed Scala Json Library

A lightweight Reactive Streams Infrastructure Toolkit for Scala.

Sentinel ⭐ 175

Boilerplate for creating reactive TCP clients / servers on Akka Streams

Akka Stream Contrib ⭐ 174

Add-ons to Akka Stream

Fs2 Aws ⭐ 163

fs2 utilities to interact with AWS

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 ⭐ 148

Streaming JSON parsing and decoding with fs2

Fs2 Rabbit ⭐ 144

🐰 RabbitMQ stream-based client built on top of Fs2

Kinesis Sql ⭐ 135

Kinesis Connector for Structured Streaming

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 ⭐ 120

Code snippets for articles posted at 4comprehension.com

Saxonsoc ⭐ 118

SoC based on VexRiscv and ICE40 UP5K

Fs2 Cron ⭐ 116

FS2 streams based on cron expressions

A Scala library for working with system processes

Embedded Kafka Schema Registry ⭐ 96

A library that provides in-memory instances of both Kafka and Confluent Schema Registry to run your tests against.

Spark Streaming Example Project ⭐ 95

A Spark Streaming job reading events from Amazon Kinesis and writing event counts to DynamoDB

Kafkastreams4s ⭐ 90

Kafka Streams for Scala. Integrates KafkaStreams with the cats-effect ecosystem

Ant's simple rule engine for Java, Java 8, Scala and Node.js.

Qstreaming ⭐ 89

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 ⭐ 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

Fastvdma ⭐ 81

Antmicro's fast, vendor-neutral DMA IP in Chisel

Reactive Viz ⭐ 77

Reactive streams (akka-streams) visualizer

An HTTP-friendly persistent message bus.

ZIO-powered client for AWS SQS

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.

Generalized, incremental parser combinators for scalaz-stream

Scala Benchmarks ⭐ 60

An independent set of benchmarks for testing common Scala idioms.

Experiments in Streaming

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

Scalaxy Streams ⭐ 57

Scalaxy/Streams: make your Scala collections faster!

Freq Count ⭐ 55

Lossy Counting and Sticky Sampling implementation for efficient frequency counts on data streams.

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 Streams Websocket Game Server ⭐ 50

Game server and client based on scala, akka streams and websocket

Akka Stream Apns ⭐ 50

Reactive Streams for APNs

Artificial Neural Networks in Akka

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?

Akka Agent ⭐ 48

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

Scala Conduits ⭐ 45

A port to Scala of the Conduit library by Michael Snoyman

Twitterstream ⭐ 45

Twitter Streaming API Example with Kafka Streams in Scala

Fdp Modelserver ⭐ 45

An umbrella project for multiple implementations of model serving

Interop Reactive Streams ⭐ 44

Interoperability Layer Between ZIO and Reactive Streams

Strymonas Scala ⭐ 43

Fast streams for Scala 3

Trembita ⭐ 43

Model complex data transformation pipelines easily

Datastax Spark Streaming Demo ⭐ 43

Counting Twitter hashtags using Spark Streaming and Cassandra

Kafka Scala Examples ⭐ 42

Examples of Avro, Kafka, Schema Registry, Kafka Streams, Interactive Queries, KSQL, Kafka Connect in Scala

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,117)

Java Scala (1,794)

Stream Streaming (1,696)

Scala Play Framework (1,309)

Plugin Scala (1,080)

1-100 of 472 search results

Privacy | About | Terms | Follow Us On Twitter

Copyright 2018-2023 Awesome Open Source. All rights reserved.