tuplejump/kafka-connect-cassandra   0.0.7

Kafka Connect Cassandra Connector. This project includes source/sink connectors for Cassandra to/from Kafka.

lightbend/kafka-streams-query   0.1.1

Library offering http based query on top of Kafka Streams Interactive Queries

softwaremill/kmq   0.3.2

Kafka-based message queue

nequissimus/circe-kafka   3.3.1

Implicit conversion of Encoder and Decoder into Serializer/Deserializer/Serde

azhur/kafka-serde-scala   0.9.0

Implicitly converts typeclass encoders to kafka Serializer, Deserializer, Serde.

banno/kafka4s   7.0.0

Functional programming with Kafka and Scala

embeddedkafka/embedded-kafka-schema-registry   8.0.0

A library that provides in-memory instances of both Kafka and Confluent Schema Registry to run your tests against.

tinkoff/gatling-kafka-plugin   0.12.1

Plugin for support Kafka in Gatling

lensesio/kafka-connect-kcql-smt   2.0.0

Kafka-Connect SMT (Single Message Transformations) with SQL syntax (Using Apache Calcite for the SQL parsing)

tuplejump/embedded-kafka   0.0.6

Embedded Kafka for testing and quick prototyping.

azure/toketi-kafka-connect-iothub   0.5

Kafka Connect IoT Hub is a Kafka source connector for pumping data from Azure IoT Hub to Kafka.

jpzk/mockedstreams   3.9.0

Scala DSL for Unit-Testing Processing Topologies in Kafka Streams

bfil/rx-kafka   0.2.0

A Scala library to create RxScala observables and observers from Kafka consumers and producers

softwaremill/ox   1.0.0

Safe direct-style streaming, concurrency and resiliency for Scala on the JVM

agoda-com/kafka-jdbc-connector   1.2.0

Simple way to copy data from relational databases into kafka.

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.

joan38/kafka-streams-circe   0.6

Generic Serdes with Circe for Kafka Streams

ogirardot/typesafe-kafka-streams   0.2.3

A started draft of a typesafe - scala - compatible API

compstak/kafkastreams4s   0.16.0

Kafka Streams for Scala. Integrates KafkaStreams with the cats-effect ecosystem

lensesio/kafka-connect-common   1.0

Common components used across the datamountaineer kafka connect connectors