-
tinkoff/gatling-kafka-plugin 0.12.1
Plugin for support Kafka in Gatling
Scala versions: 2.13 -
absaoss/hyperdrive 4.7.0
Extensible streaming ingestion pipeline on top of Apache Spark
Scala versions: 2.12 2.11 -
laserdisc-io/tamer 0.23.0
Standalone alternatives to Kafka Connect Connectors
Scala versions: 3.x 2.13 -
heartsavior/spark-sql-kafka-offset-committer 0.2.0
Kafka offset committer for structured streaming query
Scala versions: 2.12 2.11 -
lensesio/kafka-connect-kcql-smt 2.0.0
Kafka-Connect SMT (Single Message Transformations) with SQL syntax (Using Apache Calcite for the SQL parsing)
Scala versions: 2.12 -
zalando-nakadi/kanadi 0.20.0
Kanadi is a Nakadi client for Scala
Scala versions: 2.13 2.12 -
agile-lab-dev/wasp 2.35.0
WASP is a framework to build complex real time big data applications. It relies on a kind of Kappa/Lambda architecture mainly leveraging Kafka and Spark. If you need to ingest huge amount of heterogeneous data and analyze them through complex pipelines, this is the framework for you.
Scala versions: 2.12 2.11 -
nequissimus/circe-kafka 3.3.1
Implicit conversion of Encoder and Decoder into Serializer/Deserializer/Serde
Scala versions: 2.13 2.12 -
garyaiki/dendrites 0.6.3
Scala library for Reactive streaming Microservices, CQRS, Event Sourcing, Event Logging, & message-driven apps.
Scala versions: 2.12 -
romans-weapon/spear-framework 3.1.1-3.0
Rapid ETL/ELT-connectors/pipeline development leveraged on top of Apache Spark
Scala versions: 2.12 -
amient/affinity 0.15.2
Library and a Framework for building fast, scalable, fault-tolerant Data APIs based on Akka, Avro, ZooKeeper and Kafka
Scala versions: 2.12 -
jpzk/kafcache 1.3.0
Kafka Streams + Memcached (e.g. AWS ElasticCache) for low-latency in-memory lookups
Scala versions: 2.12 -
anicolaspp/minikaf 1.0.0
Minikaf is a minimal implementation of Publish / Subscriber for in memory communication.
Scala versions: 2.12 -
laserdisc-io/eisner 0.1.2
Kafka (Streams' topologies) translator
Scala versions: 2.12sbt plugins: 1.x -
tradecloud/akka-kafka 0.64
Akka Kafka wrapper to publish and subscribe to Kafka topics
Scala versions: 2.12