Reformat with scalafmt 3.9.7

Executed command: scalafmt --non-interactive

Author: scala-steward

build.sbt

@@ -5,7 +5,7 @@ inThisBuild(
     organizationHomepage := Some(url("https://github.com/azhur")),
     homepage             := Some(url("https://github.com/azhur/kafka-serde-scala")),
     licenses             := List("Apache-2.0" -> url("http://www.apache.org/licenses/LICENSE-2.0")),
-    scmInfo := Some(
+    scmInfo              := Some(
       ScmInfo(
         url("https://github.com/azhur/kafka-serde-scala"),
         "git@github.com:azhur/kafka-serde-scala.git"

kafka-serde-avro4s/src/main/scala/io/github/azhur/kafka/serde/Avro4sBinarySupport.scala

@@ -31,7 +31,7 @@ trait Avro4sBinarySupport {
     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] =
+      override def serialize(topic: String, data: T): Array[Byte]                =
         if (data == null) null
         else {
           val baos = new ByteArrayOutputStream()
@@ -54,7 +54,7 @@ trait Avro4sBinarySupport {
       private val schema                                                         = AvroSchema[T]
       override def configure(configs: util.Map[String, ?], isKey: Boolean): Unit = {}
       override def close(): Unit                                                 = {}
-      override def deserialize(topic: String, data: Array[Byte]): T =
+      override def deserialize(topic: String, data: Array[Byte]): T              =
         if (data == null) null
         else {
           val it = AvroInputStream.binary[T].from(data).build(schema).tryIterator

kafka-serde-avro4s/src/main/scala/io/github/azhur/kafka/serde/Avro4sDataSupport.scala

@@ -35,7 +35,7 @@ trait Avro4sDataSupport {
     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] =
+      override def serialize(topic: String, data: T): Array[Byte]                =
         if (data == null) null
         else {
           val baos = new ByteArrayOutputStream()
@@ -58,7 +58,7 @@ trait Avro4sDataSupport {
       private val schema                                                         = AvroSchema[T]
       override def configure(configs: util.Map[String, ?], isKey: Boolean): Unit = {}
       override def close(): Unit                                                 = {}
-      override def deserialize(topic: String, data: Array[Byte]): T =
+      override def deserialize(topic: String, data: Array[Byte]): T              =
         if (data == null) null
         else {
           val it = AvroInputStream.data[T].from(data).build(schema).tryIterator

kafka-serde-avro4s/src/main/scala/io/github/azhur/kafka/serde/Avro4sJsonSupport.scala

@@ -31,7 +31,7 @@ trait Avro4sJsonSupport {
     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] =
+      override def serialize(topic: String, data: T): Array[Byte]                =
         if (data == null) null
         else {
           val baos = new ByteArrayOutputStream()
@@ -54,7 +54,7 @@ trait Avro4sJsonSupport {
       private val schema                                                         = AvroSchema[T]
       override def configure(configs: util.Map[String, ?], isKey: Boolean): Unit = {}
       override def close(): Unit                                                 = {}
-      override def deserialize(topic: String, data: Array[Byte]): T =
+      override def deserialize(topic: String, data: Array[Byte]): T              =
         if (data == null) null
         else {
           val it = AvroInputStream.json[T].from(data).build(schema).tryIterator

kafka-serde-circe/src/main/scala/io/github/azhur/kafka/serde/CirceSupport.scala

@@ -34,7 +34,7 @@ trait CirceSupport {
       import io.circe.syntax._
       override def configure(configs: util.Map[String, ?], isKey: Boolean): Unit = {}
       override def close(): Unit                                                 = {}
-      override def serialize(topic: String, data: T): Array[Byte] =
+      override def serialize(topic: String, data: T): Array[Byte]                =
         if (data == null) null
         else
           try printer.print(data.asJson).getBytes(UTF_8)
@@ -50,7 +50,7 @@ trait CirceSupport {
 
       override def configure(configs: util.Map[String, ?], isKey: Boolean): Unit = {}
       override def close(): Unit                                                 = {}
-      override def deserialize(topic: String, data: Array[Byte]): T =
+      override def deserialize(topic: String, data: Array[Byte]): T              =
         if (data == null) null
         else
           parser

kafka-serde-jackson/src/main/scala/io/github/azhur/kafka/serde/Jackson.scala

@@ -22,8 +22,8 @@ import java.lang.reflect.{ ParameterizedType, Type => JType }
 
 object Jackson {
   def typeReference[T: TypeTag]: TypeReference[T] = {
-    val t      = typeTag[T]
-    val mirror = t.mirror
+    val t                       = typeTag[T]
+    val mirror                  = t.mirror
     def mapType(t: Type): JType =
       if (t.typeArgs.isEmpty) {
         mirror.runtimeClass(t)

kafka-serde-jackson/src/main/scala/io/github/azhur/kafka/serde/JacksonFormatSchemaSupport.scala

@@ -37,7 +37,7 @@ trait JacksonFormatSchemaSupport {
       private val writer                                                         = mapper.writer(schema)
       override def configure(configs: util.Map[String, ?], isKey: Boolean): Unit = {}
       override def close(): Unit                                                 = {}
-      override def serialize(topic: String, data: T): Array[Byte] =
+      override def serialize(topic: String, data: T): Array[Byte]                =
         if (data == null) null
         else
           try writer.writeValueAsBytes(data)
@@ -55,7 +55,7 @@ trait JacksonFormatSchemaSupport {
       private val reader = mapper.readerFor(typeReference[T]).`with`(schema)
       override def configure(configs: util.Map[String, ?], isKey: Boolean): Unit = {}
       override def close(): Unit                                                 = {}
-      override def deserialize(topic: String, data: Array[Byte]): T =
+      override def deserialize(topic: String, data: Array[Byte]): T              =
         if (data == null) null
         else
           try reader.readValue[T](data)

kafka-serde-jackson/src/main/scala/io/github/azhur/kafka/serde/JacksonJsonSupport.scala

@@ -31,7 +31,7 @@ trait JacksonJsonSupport {
     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] =
+      override def serialize(topic: String, data: T): Array[Byte]                =
         if (data == null) null
         else
           try mapper.writeValueAsBytes(data)
@@ -48,7 +48,7 @@ trait JacksonJsonSupport {
       private val tr                                                             = typeReference[T]
       override def configure(configs: util.Map[String, ?], isKey: Boolean): Unit = {}
       override def close(): Unit                                                 = {}
-      override def deserialize(topic: String, data: Array[Byte]): T =
+      override def deserialize(topic: String, data: Array[Byte]): T              =
         if (data == null) null
         else
           try mapper.readValue[T](data, tr)

kafka-serde-json4s/src/main/scala/io/github/azhur/kafka/serde/Json4sSupport.scala

@@ -33,7 +33,7 @@ trait Json4sSupport {
     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] =
+      override def serialize(topic: String, data: T): Array[Byte]                =
         if (data == null) null
         else
           try serialization.write[T](data).getBytes(UTF_8)
@@ -50,7 +50,7 @@ trait Json4sSupport {
     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 =
+      override def deserialize(topic: String, data: Array[Byte]): T              =
         if (data == null) null
         else
           try serialization.read[T](new String(data, UTF_8))

kafka-serde-jsoniter-scala/src/main/scala/io/github/azhur/kafka/serde/JsoniterScalaSupport.scala

@@ -32,7 +32,7 @@ trait JsoniterScalaSupport {
     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] =
+      override def serialize(topic: String, data: T): Array[Byte]                =
         if (data == null) null
         else
           try writeToArray(data, writerConfig)
@@ -48,7 +48,7 @@ trait JsoniterScalaSupport {
     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 =
+      override def deserialize(topic: String, data: Array[Byte]): T              =
         if (data == null) null
         else
           try readFromArray(data, readerConfig)