tradecloud/akka-kafka   0.64

Akka Kafka wrapper to publish and subscribe to Kafka topics

laserdisc-io/eisner   0.1.2

Kafka (Streams' topologies) translator

finagle/finatra-kafka   22.4.0

Easily build & test Kafka Streams applications on top of a TwitterServer with Finatra

galax-io/gatling-kafka-plugin   0.14.0

Gatling protocol plugin for supporting Kafka.

j5ik2o/akka-persistence-kafka   1.0.14

akka-persistence plugin for Apache Kafka

davideicardi/kaa   0.8.1

Avro schema registry with Kafka persistency (Kafka Avro4s Schema Registry)

maxstreese/registravka4s   0.6.0

RegistrAvKa4s - (Schema-)Registry, Avro and Kafka for Scala

jobial-io/scase   1.3.41

Run functional Scala code as a portable serverless function or microservice

farmdawgnation/kafka-detective   0.7.1

A tool for continuous end-to-end testing of streaming data applications.

trace4cats/trace4cats-kafka   0.14.3

Integration for Trace4Cats and FS2 Kafka

trace4cats/trace4cats-avro-kafka   0.14.0

Avro Kafka Exporter and Consumer for Trace4Cats

ulitol97/comet   0.1.7

Scala application for validating RDF data streams

christian-schlichtherle/circe-kafka   3.0.0

Implicit conversion of Encoder/Decoder/Codec to Serializer/Deserializer/Serde.

nequissimus/nequi-kafka   0.4.0

Kafka (Streams) extensions/helpers

maif/thoth   1.1.6

Event sourcing in java with vavr, akka stream and vertx reactive PG driver

imrafaelmerino/json-values   9.0.0-RC1

Json-values allows Java developers to harness the power of persistent data structures when working with JSON data, simplifying complex data manipulation. It provides a purely functional approach to JSON

alibaba/alink   1.6.2

Alink is the Machine Learning algorithm platform based on Flink, developed by the PAI team of Alibaba computing platform.

theinnerlight/streaming-kafka   0.8.0

FS2-derived streaming kafka library