apache/flink

Apache Flink

eclipse/deeplearning4j

Model import deployment framework for retraining models (pytorch, tensorflow,keras) deploying in JVM Micro service environments, mobile devices, iot, and Apache Spark

lagom/lagom

Reactive Microservices for the JVM

deeplearning4j/nd4j

Fast, Scientific and Numerical Computing for the JVM (NDArrays)

akka/reactive-kafka

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

snappydatainc/snappydata

Project SnappyData - memory optimized analytics database, based on Apache Spark™ and Apache Geode™. Stream, Transact, Analyze, Predict in one cluster

apache/incubator-hudi

Upserts And Incremental Processing on Big Data

gearpump/gearpump

Lightweight real-time big data streaming engine over Akka

apache/samza

Mirror of Apache Samza

twitter/storehaus

Storehaus is a library that makes it easy to work with asynchronous key value stores

druid-io/tranquility

Tranquility helps you send real-time event streams to Druid and handles partitioning, replication, service discovery, and schema rollover, seamlessly and without downtime.

conduktor/kafka-security-manager

Manage your Kafka ACL at scale

krasserm/akka-analytics

Large-scale event processing with Akka Persistence and Apache Spark

cakesolutions/scala-kafka-client

Scala helper modules for operating the Apache Kafka client library (0.9.x - 1.0.x)

manub/scalatest-embedded-kafka

A library that provides an in-memory Kafka instance to run your tests against.

wix/greyhound

Greyhound - Rich Kafka client library

krasserm/akka-persistence-kafka

A replicated Akka Persistence journal backed by Apache Kafka

sclasen/akka-kafka

jpzk/mockedstreams

Scala DSL for Unit-Testing Processing Topologies in Kafka Streams

touk/nussknacker

Process authoring tool for Apache Flink