KO | EN

GitLite

Minimalist Open Source Repository Search Engine

gitlite — search

#dsh #dsh-plugin #ai-agent #developer-tools #codex #typescript #cli #deepseek-harness #claude-code #ai-agents #mcp #rust

kafka-streams-circe

★ 29 Open GitHub ↗

Generic Serdes with Circe for Kafka Streams

// repository documentation

Was this content helpful?

★ 0 (0 ratings)

# Kafka Streams Circe

[![Latest version](https://index.scala-lang.org/joan38/kafka-streams-circe/kafka-streams-circe/latest.svg)](https://index.scala-lang.org/joan38/kafka-streams-circe/kafka-streams-circe)

Generic Serdes with [Circe](https://github.com/circe/circe) for [Kafka Streams](https://github.com/apache/kafka)

## Installation
[Mill](https://www.lihaoyi.com/mill):
```scala
ivy"com.goyeau::kafka-streams-circe:<latest version>"
```
or

[SBT](https://www.scala-sbt.org):
```scala
"com.goyeau" %% "kafka-streams-circe" % "<latest version>"
```

## Example

```scala
import org.apache.kafka.streams.scala.StreamsBuilder
import org.apache.kafka.streams.scala.ImplicitConversions._
import org.apache.kafka.streams.scala.Serdes._
import com.goyeau.kafka.streams.circe.CirceSerdes._
import io.circe.generic.auto._

case class Person(firstname: String, lastname: String, age: Int)

object Streams extends App {
  println("Starting streams")

val streamsBuilder = new StreamsBuilder
  val testStream = streamsBuilder.stream[String, Person]("some-topic")
}
```

If you need to customize the json serialization, a custom implicit instance of `Printer` can be provided in scope.

For example, in the code below a custom printer is used to omit null values:
```scala
import org.apache.kafka.streams.scala.StreamsBuilder
import org.apache.kafka.streams.scala.ImplicitConversions._
import org.apache.kafka.streams.scala.Serdes._
import com.goyeau.kafka.streams.circe.CirceSerdes._
import io.circe.generic.auto._

case class Person(firstname: String, lastname: String, age: Int)

object Streams extends App {
  implicit val printer = Printer.noSpaces.copy(dropNullValues = true)

val streamsBuilder = new StreamsBuilder
  val testStream = streamsBuilder.stream[String, Person]("some-topic")
}
```

kafka-streams-circe

Explore Similar Repositories

Was this content helpful?

Recent Feedback

Download README