From d3c7abff9507cc31b3c7af87c2d6b52962c8c5fd Mon Sep 17 00:00:00 2001
From: Adam <897017+aSemy@users.noreply.github.com>
Date: Sun, 20 Feb 2022 12:21:46 +0100
Subject: [PATCH] rm unused class (moved to kotka-streams)

---
 .../processor/serdes/binaryFormat.kt          | 50 -------------------
 1 file changed, 50 deletions(-)
 delete mode 100644 modules/events-server/src/main/kotlin/dev/adamko/kafkatorio/processor/serdes/binaryFormat.kt

diff --git a/modules/events-server/src/main/kotlin/dev/adamko/kafkatorio/processor/serdes/binaryFormat.kt b/modules/events-server/src/main/kotlin/dev/adamko/kafkatorio/processor/serdes/binaryFormat.kt
deleted file mode 100644
index 180db50..0000000
--- a/modules/events-server/src/main/kotlin/dev/adamko/kafkatorio/processor/serdes/binaryFormat.kt
+++ /dev/null
@@ -1,50 +0,0 @@
-package dev.adamko.kafkatorio.processor.serdes
-
-import kotlinx.serialization.BinaryFormat
-import kotlinx.serialization.decodeFromByteArray
-import kotlinx.serialization.encodeToByteArray
-import org.apache.kafka.common.serialization.Deserializer
-import org.apache.kafka.common.serialization.Serde
-import org.apache.kafka.common.serialization.Serializer
-
-//
-//inline fun <reified T> BinaryFormat.kafkaSerializer() =
-//  Serializer { topic: String, data: T ->
-//    runCatching {
-//      encodeToByteArray(data)
-//    }.getOrElse { e ->
-//      println(
-//        """
-//            Exception on encodeToString
-//            Topic: $topic
-//            topicData: $data
-//            topicData as T: $data
-//          """.trimIndent()
-//      )
-//      e.printStackTrace()
-//      throw e
-//    }
-//  }
-//
-//inline fun <reified T> BinaryFormat.kafkaDeserializer() =
-//  Deserializer { topic: String, data: ByteArray ->
-//    runCatching {
-//      decodeFromByteArray<T>(data)
-//    }.getOrElse { e ->
-//      println(
-//        """
-//            Exception on decodeFromString,
-//            Topic: $topic
-//            topicData: $data
-//            topicData as T: ${data as? T}
-//          """.trimIndent()
-//      )
-//      e.printStackTrace()
-//      throw e
-//    }
-//  }
-//
-//inline fun <reified T> BinaryFormat.serde() = object : Serde<T> {
-//  override fun serializer(): Serializer<T> = kafkaSerializer()
-//  override fun deserializer(): Deserializer<T> = kafkaDeserializer()
-//}