Add zio-json (#464)

azhur · web-flow · commit 9aa33e887fa6 · 2023-03-13T13:57:10.000+01:00
diff --git a/README.md b/README.md
@@ -14,6 +14,7 @@ Following target libraries are supported:
 - [play-json](https://github.com/playframework/play-json)
 - [upickle](https://github.com/lihaoyi/upickle)
 - [scalapb](https://github.com/scalapb/ScalaPB)
+- [zio-json](https://github.com/zio/zio-json)
 
 Inspired by [https://github.com/hseeberger/akka-http-json](https://github.com/hseeberger/akka-http-json).
 
@@ -26,28 +27,28 @@ Add dependencies for the selected integration:
 - for avro4s:
 ``` scala
 libraryDependencies ++= List(
-  "io.github.azhur" %% "kafka-serde-avro4s" % version,
+  "io.github.azhur" %% "kafka-serde-avro4s" % version
 )
 ```
 
 - for circe:
 ``` scala
 libraryDependencies ++= List(
-  "io.github.azhur" %% "kafka-serde-circe" % version,
+  "io.github.azhur" %% "kafka-serde-circe" % version
 )
 ```
 
 - for jackson:
 ``` scala
 libraryDependencies ++= List(
-  "io.github.azhur" %% "kafka-serde-jackson" % version,
+  "io.github.azhur" %% "kafka-serde-jackson" % version
 )
 ```
 
 - for json4s:
 ``` scala
 libraryDependencies ++= List(
-  "io.github.azhur" %% "kafka-serde-json4s" % version,
+  "io.github.azhur" %% "kafka-serde-json4s" % version
 )
 ```
 
@@ -80,6 +81,13 @@ libraryDependencies ++= List(
 )
 ```
 
+- for zio-json:
+``` scala
+libraryDependencies ++= List(
+  "io.github.azhur" %% "kafka-serde-zio-json" % version
+)
+```
+
 ## Usage
 
 Mix `xxxSupport` into your code which requires implicit Kafka 
@@ -96,6 +104,7 @@ Provide your implicit type class instances and the magic will convert them to Ka
 - for play-json: `play.api.libs.json.Reads`, `play.api.libs.json.Writes`  
 - for upickle: `upickle.default.Reader`, `upickle.default.Writer`  
 - for scalapb: `scalapb.GeneratedMessageCompanion`
+- for zio-json: `zio.json.JsonEncoder`, `zio.json.JsonDecoder`
 
 For more info, please, take a look at unit tests and at `kafka-serde-scala-example` which is a kafka-streams (2.x) application with kafka-serde-scala usage.
 
diff --git a/build.sbt b/build.sbt
@@ -26,7 +26,7 @@ lazy val latest212 = "2.12.17"
 
 lazy val latest213 = "2.13.10"
 
-lazy val latest3 = "3.2.1"
+lazy val latest3 = "3.2.2"
 
 lazy val `kafka-serde-scala` =
   project
@@ -41,6 +41,7 @@ lazy val `kafka-serde-scala` =
       `kafka-serde-play-json`,
       `kafka-serde-upickle`,
       `kafka-serde-scalapb`,
+      `kafka-serde-zio-json`,
       `kafka-serde-scala-example`
     )
     .settings(commonSettings)
@@ -167,6 +168,22 @@ lazy val `kafka-serde-scalapb` = project
   .settings(
     Compile / PB.targets := Seq(
       scalapb.gen() -> (Compile / sourceManaged).value / "scalapb"
+    ),
+    Test / PB.targets := Seq(
+      scalapb.gen() -> (Test / sourceManaged).value / "scalapb"
+    )
+  )
+
+lazy val `kafka-serde-zio-json` = project
+  .enablePlugins(AutomateHeaderPlugin)
+  .settings(commonSettings)
+  .settings(mimaSettings)
+  .settings(
+    crossScalaVersions := Seq(latest212, latest213, latest3),
+    libraryDependencies ++= Seq(
+      dependency.kafkaClients,
+      dependency.zioJson,
+      dependency.scalaTest % Test
     )
   )
 
@@ -196,6 +213,7 @@ lazy val dependency =
       val play          = "2.9.4"
       val upickle       = "3.0.0"
       val jackson       = "2.14.2"
+      val zioJson       = "0.4.2"
     }
     val kafkaClients        = "org.apache.kafka"                       % "kafka-clients"         % Version.kafka
     val kafkaStreamsScala   = "org.apache.kafka"                      %% "kafka-streams-scala"   % Version.kafka
@@ -214,6 +232,7 @@ lazy val dependency =
     val upickle             = "com.lihaoyi"                           %% "upickle"               % Version.upickle
     val jacksonScala        = "com.fasterxml.jackson.module"          %% "jackson-module-scala"  % Version.jackson
     val jacksonCore         = "com.fasterxml.jackson.core"             % "jackson-core"          % Version.jackson
+    val zioJson             = "dev.zio"                               %% "zio-json"              % Version.zioJson
     val jacksonProtobuf = "com.fasterxml.jackson.dataformat" % "jackson-dataformat-protobuf" % Version.jackson
     val jacksonAvro     = "com.fasterxml.jackson.dataformat" % "jackson-dataformat-avro"     % Version.jackson
     val scalaTest       = "org.scalatest"                   %% "scalatest"                   % Version.scalaTest
diff --git a/kafka-serde-avro4s/src/main/scala/io/github/azhur/kafka/serde/Avro4sBinarySupport.scala b/kafka-serde-avro4s/src/main/scala/io/github/azhur/kafka/serde/Avro4sBinarySupport.scala
@@ -14,7 +14,7 @@
  * limitations under the License.
  */
 
-package io.github.azhur.kafkaserdeavro4s
+package io.github.azhur.kafka.serde
 
 import java.io.ByteArrayOutputStream
 import java.util
diff --git a/kafka-serde-avro4s/src/main/scala/io/github/azhur/kafka/serde/Avro4sDataSupport.scala b/kafka-serde-avro4s/src/main/scala/io/github/azhur/kafka/serde/Avro4sDataSupport.scala
@@ -14,7 +14,7 @@
  * limitations under the License.
  */
 
-package io.github.azhur.kafkaserdeavro4s
+package io.github.azhur.kafka.serde
 
 import java.io.ByteArrayOutputStream
 import java.util
diff --git a/kafka-serde-avro4s/src/main/scala/io/github/azhur/kafka/serde/Avro4sJsonSupport.scala b/kafka-serde-avro4s/src/main/scala/io/github/azhur/kafka/serde/Avro4sJsonSupport.scala
@@ -14,7 +14,7 @@
  * limitations under the License.
  */
 
-package io.github.azhur.kafkaserdeavro4s
+package io.github.azhur.kafka.serde
 
 import java.io.ByteArrayOutputStream
 import java.util
diff --git a/kafka-serde-avro4s/src/test/scala/io/github/azhur/kafka/serde/Avro4sBinarySupportSpec.scala b/kafka-serde-avro4s/src/test/scala/io/github/azhur/kafka/serde/Avro4sBinarySupportSpec.scala
@@ -14,7 +14,7 @@
  * limitations under the License.
  */
 
-package io.github.azhur.kafkaserdeavro4s
+package io.github.azhur.kafka.serde
 
 import com.sksamuel.avro4s.{ Decoder, Encoder, SchemaFor }
 import org.apache.kafka.common.serialization.{ Deserializer, Serde, Serializer }
diff --git a/kafka-serde-avro4s/src/test/scala/io/github/azhur/kafka/serde/Avro4sDataSupportSpec.scala b/kafka-serde-avro4s/src/test/scala/io/github/azhur/kafka/serde/Avro4sDataSupportSpec.scala
@@ -14,7 +14,7 @@
  * limitations under the License.
  */
 
-package io.github.azhur.kafkaserdeavro4s
+package io.github.azhur.kafka.serde
 
 import com.sksamuel.avro4s.{ Decoder, Encoder, SchemaFor }
 import org.apache.kafka.common.serialization.{ Deserializer, Serde, Serializer }
diff --git a/kafka-serde-avro4s/src/test/scala/io/github/azhur/kafka/serde/Avro4sJsonSupportSpec.scala b/kafka-serde-avro4s/src/test/scala/io/github/azhur/kafka/serde/Avro4sJsonSupportSpec.scala
@@ -14,7 +14,7 @@
  * limitations under the License.
  */
 
-package io.github.azhur.kafkaserdeavro4s
+package io.github.azhur.kafka.serde
 
 import java.nio.charset.StandardCharsets.UTF_8
 
diff --git a/kafka-serde-circe/src/main/scala/io/github/azhur/kafka/serde/CirceSupport.scala b/kafka-serde-circe/src/main/scala/io/github/azhur/kafka/serde/CirceSupport.scala
@@ -14,7 +14,7 @@
  * limitations under the License.
  */
 
-package io.github.azhur.kafkaserdecirce
+package io.github.azhur.kafka.serde
 
 import java.nio.charset.StandardCharsets.UTF_8
 import java.util
diff --git a/kafka-serde-circe/src/test/scala/io/github/azhur/kafka/serde/CirceSupportSpec.scala b/kafka-serde-circe/src/test/scala/io/github/azhur/kafka/serde/CirceSupportSpec.scala
@@ -14,7 +14,7 @@
  * limitations under the License.
  */
 
-package io.github.azhur.kafkaserdecirce
+package io.github.azhur.kafka.serde
 
 import java.nio.charset.StandardCharsets.UTF_8
 
diff --git a/kafka-serde-jackson/src/main/scala/io/github/azhur/kafka/serde/Jackson.scala b/kafka-serde-jackson/src/main/scala/io/github/azhur/kafka/serde/Jackson.scala
@@ -14,7 +14,7 @@
  * limitations under the License.
  */
 
-package io.github.azhur.kafkaserdejackson
+package io.github.azhur.kafka.serde
 
 import com.fasterxml.jackson.core.`type`.TypeReference
 import scala.reflect.runtime.universe._
diff --git a/kafka-serde-jackson/src/main/scala/io/github/azhur/kafka/serde/JacksonFormatSchemaSupport.scala b/kafka-serde-jackson/src/main/scala/io/github/azhur/kafka/serde/JacksonFormatSchemaSupport.scala
@@ -14,7 +14,7 @@
  * limitations under the License.
  */
 
-package io.github.azhur.kafkaserdejackson
+package io.github.azhur.kafka.serde
 
 import java.util
 
diff --git a/kafka-serde-jackson/src/main/scala/io/github/azhur/kafka/serde/JacksonJsonSupport.scala b/kafka-serde-jackson/src/main/scala/io/github/azhur/kafka/serde/JacksonJsonSupport.scala
@@ -14,7 +14,7 @@
  * limitations under the License.
  */
 
-package io.github.azhur.kafkaserdejackson
+package io.github.azhur.kafka.serde
 
 import java.util
 
diff --git a/kafka-serde-jackson/src/test/scala/io/github/azhur/kafka/serde/ApiSpec.scala b/kafka-serde-jackson/src/test/scala/io/github/azhur/kafka/serde/ApiSpec.scala
@@ -14,7 +14,7 @@
  * limitations under the License.
  */
 
-package io.github.azhur.kafkaserdejackson
+package io.github.azhur.kafka.serde
 
 import org.apache.kafka.common.serialization.{ Deserializer, Serde, Serializer }
 
diff --git a/kafka-serde-jackson/src/test/scala/io/github/azhur/kafka/serde/JacksonFormatSchemaSupportSpec.scala b/kafka-serde-jackson/src/test/scala/io/github/azhur/kafka/serde/JacksonFormatSchemaSupportSpec.scala
@@ -14,7 +14,7 @@
  * limitations under the License.
  */
 
-package io.github.azhur.kafkaserdejackson
+package io.github.azhur.kafka.serde
 
 import com.fasterxml.jackson.dataformat.avro.{ AvroMapper, AvroSchema }
 import com.fasterxml.jackson.dataformat.protobuf.ProtobufMapper
diff --git a/kafka-serde-jackson/src/test/scala/io/github/azhur/kafka/serde/JacksonJsonSupportSpec.scala b/kafka-serde-jackson/src/test/scala/io/github/azhur/kafka/serde/JacksonJsonSupportSpec.scala
@@ -14,7 +14,7 @@
  * limitations under the License.
  */
 
-package io.github.azhur.kafkaserdejackson
+package io.github.azhur.kafka.serde
 
 import com.fasterxml.jackson.databind.ObjectMapper
 import com.fasterxml.jackson.module.scala.DefaultScalaModule
diff --git a/kafka-serde-json4s/src/main/scala/io/github/azhur/kafka/serde/Json4sSupport.scala b/kafka-serde-json4s/src/main/scala/io/github/azhur/kafka/serde/Json4sSupport.scala
@@ -14,7 +14,7 @@
  * limitations under the License.
  */
 
-package io.github.azhur.kafkaserdejson4s
+package io.github.azhur.kafka.serde
 
 import java.nio.charset.StandardCharsets.UTF_8
 import java.util
diff --git a/kafka-serde-json4s/src/test/scala/io/github/azhur/kafka/serde/Json4sSupportSpec.scala b/kafka-serde-json4s/src/test/scala/io/github/azhur/kafka/serde/Json4sSupportSpec.scala
@@ -14,7 +14,7 @@
  * limitations under the License.
  */
 
-package io.github.azhur.kafkaserdejson4s
+package io.github.azhur.kafka.serde
 
 import java.nio.charset.StandardCharsets.UTF_8
 
diff --git a/kafka-serde-jsoniter-scala/src/main/scala/io/github/azhur/kafka/serde/JsoniterScalaSupport.scala b/kafka-serde-jsoniter-scala/src/main/scala/io/github/azhur/kafka/serde/JsoniterScalaSupport.scala
@@ -14,7 +14,7 @@
  * limitations under the License.
  */
 
-package io.github.azhur.kafkaserdejsoniterscala
+package io.github.azhur.kafka.serde
 
 import java.util
 
diff --git a/kafka-serde-jsoniter-scala/src/test/scala/io/github/azhur/kafka/serde/JsoniterScalaSupportSpec.scala b/kafka-serde-jsoniter-scala/src/test/scala/io/github/azhur/kafka/serde/JsoniterScalaSupportSpec.scala
@@ -14,7 +14,7 @@
  * limitations under the License.
  */
 
-package io.github.azhur.kafkaserdejsoniterscala
+package io.github.azhur.kafka.serde
 
 import java.nio.charset.StandardCharsets.UTF_8
 
@@ -42,7 +42,7 @@ object JsoniterScalaSupportSpec {
 
 class JsoniterScalaSupportSpec extends AnyFreeSpec with Matchers {
   import JsoniterScalaSupportSpec._
-  import io.github.azhur.kafkaserdejsoniterscala.JsoniterScalaSupport._
+  import JsoniterScalaSupport._
 
   implicit private val fooCodec: JsonValueCodec[Foo] = JsonCodecMaker.make[Foo]
 
diff --git a/kafka-serde-play-json/src/main/scala/io/github/azhur/kafka/serde/PlayJsonSupport.scala b/kafka-serde-play-json/src/main/scala/io/github/azhur/kafka/serde/PlayJsonSupport.scala
@@ -14,12 +14,12 @@
  * limitations under the License.
  */
 
-package io.github.azhur.kafkaserdeplayjson
+package io.github.azhur.kafka.serde
 
 import java.nio.charset.StandardCharsets.UTF_8
 import java.util
 
-import io.github.azhur.kafkaserdeplayjson.PlayJsonSupport.PlayJsonError
+import PlayJsonSupport.PlayJsonError
 import org.apache.kafka.common.errors.SerializationException
 import org.apache.kafka.common.serialization.{ Deserializer, Serde, Serializer }
 import play.api.libs.json.{ JsError, JsValue, Json, Reads, Writes }
diff --git a/kafka-serde-play-json/src/test/scala/io/github/azhur/kafka/serde/PlayJsonSupportSpec.scala b/kafka-serde-play-json/src/test/scala/io/github/azhur/kafka/serde/PlayJsonSupportSpec.scala
@@ -14,7 +14,7 @@
  * limitations under the License.
  */
 
-package io.github.azhur.kafkaserdeplayjson
+package io.github.azhur.kafka.serde
 
 import java.nio.charset.StandardCharsets.UTF_8
 
@@ -43,7 +43,7 @@ object PlayJsonSupportSpec {
 
 class PlayJsonSupportSpec extends AnyFreeSpec with Matchers {
   import PlayJsonSupportSpec._
-  import io.github.azhur.kafkaserdeplayjson.PlayJsonSupport._
+  import PlayJsonSupport._
 
   "PlayJsonSupport" - {
     "should implicitly convert to kafka Serializer" in {
diff --git a/kafka-serde-scala-example/src/main/scala/io/github/azhur/kafka/serde/Application.scala b/kafka-serde-scala-example/src/main/scala/io/github/azhur/kafka/serde/Application.scala
@@ -14,10 +14,10 @@
  * limitations under the License.
  */
 
-package io.github.azhur.kafkaserdescala.example
-import java.util.Properties
+package io.github.azhur.kafka.serde
 
-import io.github.azhur.kafkaserdecirce.CirceSupport
+import io.github.azhur.kafka.serde.CirceSupport
+import java.util.Properties
 import org.apache.kafka.clients.consumer.ConsumerConfig
 import org.apache.kafka.streams.{ KafkaStreams, StreamsConfig, Topology }
 import org.apache.kafka.streams.scala.StreamsBuilder
diff --git a/kafka-serde-scalapb/src/main/scala/io/github/azhur/kafka/serde/ScalaPbSupport.scala b/kafka-serde-scalapb/src/main/scala/io/github/azhur/kafka/serde/ScalaPbSupport.scala
@@ -14,7 +14,7 @@
  * limitations under the License.
  */
 
-package io.github.azhur.kafkaserdescalapb
+package io.github.azhur.kafka.serde
 
 import org.apache.kafka.common.serialization.Serializer
 import scalapb.GeneratedMessageCompanion
diff --git a/kafka-serde-scalapb/src/test/protobuf/SearchRequest.proto b/kafka-serde-scalapb/src/test/protobuf/SearchRequest.proto
@@ -1,6 +1,6 @@
 syntax = "proto2";
 
-package io.github.azhur.scalaserdescalapb.proto;
+package io.github.azhur.serde.proto;
 
 message SearchRequest {
   required string query = 1;
diff --git a/kafka-serde-scalapb/src/test/scala/io/github/azhur/kafka/serde/ScalaPbSupportSpec.scala b/kafka-serde-scalapb/src/test/scala/io/github/azhur/kafka/serde/ScalaPbSupportSpec.scala
@@ -14,12 +14,12 @@
  * limitations under the License.
  */
 
-package io.github.azhur.kafkaserdescalapb
+package io.github.azhur.kafka.serde
 
 import org.apache.kafka.common.serialization.{ Deserializer, Serde, Serializer }
 import org.scalatest.freespec.AnyFreeSpec
 import org.scalatest.matchers.should.Matchers
-import io.github.azhur.scalaserdescalapb.proto.SearchRequest.SearchRequest
+import io.github.azhur.serde.proto.SearchRequest.SearchRequest
 import scalapb.GeneratedMessageCompanion
 
 object ScalaPbSupportSpec {
diff --git a/kafka-serde-upickle/src/main/scala/io/github/azhur/kafka/serde/UpickleSupport.scala b/kafka-serde-upickle/src/main/scala/io/github/azhur/kafka/serde/UpickleSupport.scala
@@ -14,7 +14,7 @@
  * limitations under the License.
  */
 
-package io.github.azhur.kafkaserdeupickle
+package io.github.azhur.kafka.serde
 
 import java.nio.charset.StandardCharsets.UTF_8
 import java.util
diff --git a/kafka-serde-upickle/src/test/scala/io/github/azhur/kafka/serde/UpickleSupportSpec.scala b/kafka-serde-upickle/src/test/scala/io/github/azhur/kafka/serde/UpickleSupportSpec.scala
@@ -14,7 +14,7 @@
  * limitations under the License.
  */
 
-package io.github.azhur.kafkaserdeupickle
+package io.github.azhur.kafka.serde
 
 import java.nio.charset.StandardCharsets.UTF_8
 
diff --git a/kafka-serde-zio-json/src/main/scala/io/github/azhur/kafka/serde/ZioJsonSupport.scala b/kafka-serde-zio-json/src/main/scala/io/github/azhur/kafka/serde/ZioJsonSupport.scala
diff --git a/kafka-serde-zio-json/src/test/scala/io/github/azhur/kafka/serde/ZioJsonSupportSpec.scala b/kafka-serde-zio-json/src/test/scala/io/github/azhur/kafka/serde/ZioJsonSupportSpec.scala

-Original file line number
+Diff line change
 +/*
 + * Copyright 2023 Artur Zhurat
 + *
 + * Licensed under the Apache License, Version 2.0 (the "License");
 + * you may not use this file except in compliance with the License.
 + * You may obtain a copy of the License at
 + *
 + *     http://www.apache.org/licenses/LICENSE-2.0
 + *
 + * Unless required by applicable law or agreed to in writing, software
 + * distributed under the License is distributed on an "AS IS" BASIS,
 + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 + * See the License for the specific language governing permissions and
 + * limitations under the License.
 + */
++
 +package io.github.azhur.kafka.serde
++
 +import java.nio.charset.StandardCharsets.UTF_8
 +import java.util
++
 +import org.apache.kafka.common.errors.SerializationException
 +import org.apache.kafka.common.serialization.{ Deserializer, Serde, Serializer }
 +import zio.json._
++
 +import scala.util.control.NonFatal
++
 +trait ZioJsonSupport {
 +  implicit def toSerializer[T >: Null](implicit encoder: JsonEncoder[T]): Serializer[T] =
 +    new Serializer[T] {
 +      override def configure(configs: util.Map[String, _], isKey: Boolean): Unit = {}
 +      override def close(): Unit                                                 = {}
 +      override def serialize(topic: String, data: T): Array[Byte] =
 +        if (data == null) null
 +        else
 +          try data.toJson.getBytes(UTF_8)
 +          catch {
 +            case NonFatal(e) => throw new SerializationException(e)
 +          }
 +    }
++
 +  implicit def toDeserializer[T >: Null](implicit decoder: JsonDecoder[T]): Deserializer[T] =
 +    new Deserializer[T] {
 +      override def configure(configs: util.Map[String, _], isKey: Boolean): Unit = {}
 +      override def close(): Unit                                                 = {}
 +      override def deserialize(topic: String, data: Array[Byte]): T =
 +        if (data == null) null
 +        else
 +          decoder.decodeJson(new String(data, UTF_8)) match {
 +            case Left(value)  => throw new SerializationException(value)
 +            case Right(value) => value
 +          }
 +    }
++
 +  implicit def toSerde[T >: Null](implicit encoder: JsonEncoder[T], decoder: JsonDecoder[T]): Serde[T] =
 +    new Serde[T] {
 +      override def configure(configs: util.Map[String, _], isKey: Boolean): Unit = {}
 +      override def close(): Unit                                                 = {}
 +      override def serializer(): Serializer[T]                                   = toSerializer[T]
 +      override def deserializer(): Deserializer[T]                               = toDeserializer[T]
 +    }
 +}
++
 +object ZioJsonSupport extends ZioJsonSupport
-Original file line number
+Diff line change
 +/*
 + * Copyright 2023 Artur Zhurat
 + *
 + * Licensed under the Apache License, Version 2.0 (the "License");
 + * you may not use this file except in compliance with the License.
 + * You may obtain a copy of the License at
 + *
 + *     http://www.apache.org/licenses/LICENSE-2.0
 + *
 + * Unless required by applicable law or agreed to in writing, software
 + * distributed under the License is distributed on an "AS IS" BASIS,
 + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 + * See the License for the specific language governing permissions and
 + * limitations under the License.
 + */
++
 +package io.github.azhur.kafka.serde
++
 +import java.nio.charset.StandardCharsets.UTF_8
 +import org.apache.kafka.common.serialization.{ Deserializer, Serde, Serializer }
 +import org.scalatest.freespec.AnyFreeSpec
 +import org.scalatest.matchers.should.Matchers
 +import zio.json._
++
 +object ZioJsonSupportSpec {
 +  case class Foo(a: Int, b: String)
++
 +  def serializeFoo(foo: Foo)(implicit serializer: Serializer[Foo]): Array[Byte] =
 +    serializer.serialize("unused_topic", foo)
++
 +  def deserializeFoo(bytes: Array[Byte])(implicit deserializer: Deserializer[Foo]): Foo =
 +    deserializer.deserialize("unused_topic", bytes)
++
 +  def serdeFooDes(bytes: Array[Byte])(implicit serde: Serde[Foo]): Foo =
 +    serde.deserializer().deserialize("unused_topic", bytes)
++
 +  def serdeFooSer(foo: Foo)(implicit serde: Serde[Foo]): Array[Byte] =
 +    serde.serializer().serialize("unused_topic", foo)
++
 +  implicit val decoder: JsonDecoder[Foo] = DeriveJsonDecoder.gen[Foo]
 +  implicit val encoder: JsonEncoder[Foo] = DeriveJsonEncoder.gen[Foo]
 +}
++
 +class ZioJsonSupportSpec extends AnyFreeSpec with Matchers {
 +  import ZioJsonSupport._
 +  import ZioJsonSupportSpec._
++
 +  "ZioJsonSupport" - {
 +    "should implicitly convert to kafka Serializer" in {
 +      serializeFoo(Foo(1, "𝄞")) shouldBe """{"a":1,"b":"𝄞"}""".getBytes(UTF_8)
 +      serializeFoo(null) shouldBe null
 +    }
++
 +    "should implicitly convert to kafka Deserializer" in {
 +      deserializeFoo("""{"a":1,"b":"𝄞"}""".getBytes(UTF_8)) shouldBe Foo(1, "𝄞")
 +      deserializeFoo(null) shouldBe null
 +    }
++
 +    "should implicitly convert to kafka Serde" in {
 +      val foo           = Foo(1, "𝄞")
 +      val serializedFoo = """{"a":1,"b":"𝄞"}""".getBytes(UTF_8)
++
 +      serdeFooDes(serializedFoo) shouldBe foo
 +      serdeFooDes(null) shouldBe null
++
 +      serdeFooSer(foo) shouldBe serializedFoo
 +      serdeFooSer(null) shouldBe null
 +    }
 +  }
 +}