NeQuissimus/circe-kafka

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

Language: Scala - Size: 272 KB - Last synced at: 5 months ago - Pushed at: 5 months ago - Stars: 24 - Forks: 3

niqdev/zio-kafka-streams

Kafka Streams for Scala with ZIO

Language: Scala - Size: 147 KB - Last synced at: 3 months ago - Pushed at: almost 4 years ago - Stars: 14 - Forks: 0

jpzk/kafcache

Kafka Streams + Memcached (e.g. AWS ElasticCache) for low-latency in-memory lookups

Language: Scala - Size: 30.3 KB - Last synced at: almost 2 years ago - Pushed at: over 5 years ago - Stars: 13 - Forks: 0

InternityFoundation/kafka-streams-scala-starter-kit

This repository is a demonstration of how to use kafka-streams-scala from Lightbend in your scala code

Language: Scala - Size: 11.7 KB - Last synced at: over 2 years ago - Pushed at: over 7 years ago - Stars: 10 - Forks: 1

deliveroo/roowhoo_dashboard 📦

Kafka active consumers dashboard

Language: Scala - Size: 82 KB - Last synced at: almost 2 years ago - Pushed at: over 6 years ago - Stars: 7 - Forks: 0

NeQuissimus/nequi-kafka

Kafka (Streams) extensions/helpers

Language: Scala - Size: 203 KB - Last synced at: 5 months ago - Pushed at: 5 months ago - Stars: 0 - Forks: 3

fhuertas/uah-angvd-2019

Language: Scala - Size: 7.63 MB - Last synced at: almost 2 years ago - Pushed at: over 2 years ago - Stars: 0 - Forks: 0

szczepanja/kafka-word-count

Language: Scala - Size: 4.88 KB - Last synced at: over 2 years ago - Pushed at: about 3 years ago - Stars: 0 - Forks: 0

knoldus/joined-kafka-streams-example.g8

A basic application to show how we can join two or more kafka streams.

Language: Scala - Size: 17.6 KB - Last synced at: over 2 years ago - Pushed at: about 7 years ago - Stars: 0 - Forks: 0