Search depends-on:apache/kafka

scala kafka

16564 8808 336

apache/flink

Apache Flink

scala java big-data flink

13905 7562 277

eclipse/deeplearning4j

Eclipse Deeplearning4j, ND4J, DataVec and more - deep learning & linear algebra for Java/Scala with GPUs + Spark

spark python scala clojure matrix-library linear-algebra java dl4j deeplearning4j hadoop intellij deeplearning gpu neural-nets artificial-intelligence

11622 4821 37

lagom/lagom

Reactive Microservices for the JVM

Sbt: 0.13 1.0

distributed-systems akka scala hacktoberfest play java playframework lagom microservices reactive

2483 598 133

twitter/finatra

Fast, testable, Scala services built on TwitterServer and Finagle

scala guice http finagle twitter-server thrift framework slf4j microservices testing

2050 377 154

datastax/spark-cassandra-connector

DataStax Spark Cassandra Connector

cassandra scala spark

1738 836 86

deeplearning4j/nd4j

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

spark jvm artificial-intelligence scala-notebook scientific-computing nd4j java scientific backend gpu dl4j numerical-calculations

1524 526 81

akka/alpakka-kafka

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

scala akka-streams java kafka-client kafka-connector kafka reactive akka reactive-streams

1288 370 95

apache/hudi

Upserts, Deletes And Incremental Processing on Big Data.

Scala (JVM): 2.11 2.12

apachehudi apachespark incremental-processing data-integration datalake hudi bigdata stream-processing

1212 519 107

akka/reactive-kafka

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

1064 298 64

locationtech/geomesa

GeoMesa is a suite of tools for working with big geo-spatial data in a distributed fashion.

Scala (JVM): 2.11

1029 350 84

snappydatainc/snappydata

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

spark stream snappydata transaction analytics scale memory-database

988 190 41

apache/incubator-hudi

Upserts And Incremental Processing on Big Data

Scala (JVM): 2.11 2.12

hudi

956 370 80

gearpump/gearpump

Lightweight real-time big data streaming engine over Akka

akka stream-processing

676 140 26

apache/samza

Mirror of Apache Samza

scala big-data samza

671 279 120

twitter/storehaus

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

429 74 29

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.

361 200 18

krasserm/akka-analytics

Large-scale event processing with Akka Persistence and Apache Spark

270 36 2

cakesolutions/scala-kafka-client

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

Scala (JVM): 2.11 2.12

scala kafka akka

266 71 17

manub/scalatest-embedded-kafka

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