11 results
-
jpzk/mockedstreams
Scala DSL for Unit-Testing Processing Topologies in Kafka Streams
Scala versions: 2.13 2.12 2.11 -
azhur/kafka-serde-scala
Implicitly converts typeclass encoders to kafka Serializer, Deserializer, Serde.
Scala versions: 3.x 2.13 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 -
jpzk/kafcache
Kafka Streams + Memcached (e.g. AWS ElasticCache) for low-latency in-memory lookups
Scala versions: 2.12 -
laserdisc-io/eisner
Kafka (Streams' topologies) translator
Scala versions: 2.12sbt plugins: 1.0 -
nequissimus/nequi-kafka
Kafka (Streams) extensions/helpers
Scala versions: 2.12 2.11 -
openshine/kafka-streams-scala
Typesafe Scala wrapper around the Kafka Streams Java API
Scala versions: 2.12 2.11