-
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.21.3
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 -
otavia-projects/otavia 0.4.5
Your shiny new IO & Actor programming model! ❤️❤️❤️ Star Me Please 👆👆👆
Scala versions: 3.x -
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 -
apache/pekko-connectors-kafka 1.1.0
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 -
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 -
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 -
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 -
kaizen-solutions/fs2-kafka-jsonschema-support 0.7.0
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