-
tinkoff/gatling-kafka-plugin
Plugin for support Kafka in Gatling
Scala versions: 2.13 2.12 -
absaoss/hyperdrive
Extensible streaming ingestion pipeline on top of Apache Spark
Scala versions: 2.12 2.11 -
laserdisc-io/tamer
Standalone alternatives to Kafka Connect Connectors
Scala versions: 3.x 2.13 2.12 -
heartsavior/spark-sql-kafka-offset-committer
Kafka offset committer for structured streaming query
Scala versions: 2.12 2.11 -
lensesio/kafka-connect-kcql-smt
Kafka-Connect SMT (Single Message Transformations) with SQL syntax (Using Apache Calcite for the SQL parsing)
Scala versions: 2.12 2.11 -
zalando-nakadi/kanadi
Kanadi is a Nakadi client for Scala
Scala versions: 2.13 2.12 2.11 -
agile-lab-dev/wasp
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
Implicit conversion of Encoder and Decoder into Serializer/Deserializer/Serde
Scala versions: 2.13 2.12 2.11 -
garyaiki/dendrites
Scala library for Reactive streaming Microservices, CQRS, Event Sourcing, Event Logging, & message-driven apps.
Scala versions: 2.12 2.11 -
amient/affinity
Library and a Framework for building fast, scalable, fault-tolerant Data APIs based on Akka, Avro, ZooKeeper and Kafka
Scala versions: 2.12 2.11 -
romans-weapon/spear-framework
Rapid ETL/ELT-connectors/pipeline development leveraged on top of Apache Spark
Scala versions: 2.12 2.11 -
apache/pekko-connectors-kafka
Apache Pekko Kafka Connector - Pekko-Connectors is a Reactive Enterprise Integration library for Java and Scala, based on Reactive Streams and Apache Pekko.
Scala versions: 3.x 2.13 2.12 -
jpzk/kafcache
Kafka Streams + Memcached (e.g. AWS ElasticCache) for low-latency in-memory lookups
Scala versions: 2.12 -
anicolaspp/minikaf
Minikaf is a minimal implementation of Publish / Subscriber for in memory communication.
Scala versions: 2.12 -
kaizen-solutions/fs2-kafka-jsonschema-support
Provides FS2 Kafka Serializers/Deserializers that validate and integrate JSON Schema with Confluent Schema Registry and publish JSON that adheres to the JSON schema
Scala versions: 2.13 2.12 -
tradecloud/akka-kafka
Akka Kafka wrapper to publish and subscribe to Kafka topics
Scala versions: 2.12 2.11