niqdev / kafka-scala-examples
Examples of Avro, Kafka, Schema Registry, Kafka Streams, Interactive Queries, KSQL, Kafka Connect in Scala
☆63Updated 3 months ago
Related projects ⓘ
Alternatives and complementary repositories for kafka-scala-examples
- Lego bricks to build Apache Kafka serializers and deserializers☆119Updated last year
- Type safety for spark columns☆76Updated 2 weeks ago
- Functional programming with Kafka and Scala☆92Updated 2 weeks ago
- Optics for Spark DataFrames☆47Updated 3 years ago
- Functional Avro for Scala☆102Updated last week
- Boiler plate framework to use Spark and ZIO together.☆175Updated 3 months ago
- Functional Kafka Streams for Scala☆293Updated this week
- Flink Scala API is a thin wrapper on top of Flink Java API which support Scala Types for serialisation as well the latest Scala version☆67Updated last week
- Generic Serdes with Circe for Kafka Streams☆28Updated 2 years ago
- ☆44Updated 4 years ago
- Thin Scala wrapper around Kafka Streams Java API☆190Updated last year
- A library that provides in-memory instances of both Kafka and Confluent Schema Registry to run your tests against.☆111Updated 2 weeks ago
- The repository for the Functional Scala workshop.☆177Updated 4 years ago
- A collection of Magnolia add-on modules☆167Updated this week
- A functional wrapper around Spark to make it works with ZIO☆42Updated this week
- Minimal, idiomatic, stream-based Scala interface for key/value store implementations☆59Updated this week
- Example Scala API to bootstrap new projects☆56Updated last year
- Minimal http4s + Doobie + ZIO + Circe Scala application to show how to build a purely functional web application in Scala.☆125Updated 4 years ago
- ☆89Updated 10 months ago
- Scala 3.x wrapper for Apache Flink☆49Updated last year
- Monix integration with Kafka☆123Updated 3 months ago
- Idiomatic, typesafe, and reactive Scala client for Apache Pulsar☆227Updated 2 months ago
- Purely functional Apache Pulsar client for Scala built on top of Fs2☆71Updated 2 weeks ago
- Yet another Typesafe config Scala wrapper powered by circe☆122Updated last month
- An sbt plugin for missinglink☆133Updated 5 months ago
- Scala JSON Schema☆123Updated 2 months ago
- The official repository for the Rock the JVM Cats course☆62Updated 4 months ago
- Event sourcing journal implementation using Kafka as main storage☆112Updated last week
- sbt plugin for compiling Avro schemas, similar to sbt-protobuf☆33Updated last week
- A schema-aware Scala library for data transformation☆86Updated 8 months ago