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 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 BinaryFormat.kafkaDeserializer() = -// Deserializer { topic: String, data: ByteArray -> -// runCatching { -// decodeFromByteArray(data) -// }.getOrElse { e -> -// println( -// """ -// Exception on decodeFromString, -// Topic: $topic -// topicData: $data -// topicData as T: ${data as? T} -// """.trimIndent() -// ) -// e.printStackTrace() -// throw e -// } -// } -// -//inline fun BinaryFormat.serde() = object : Serde { -// override fun serializer(): Serializer = kafkaSerializer() -// override fun deserializer(): Deserializer = kafkaDeserializer() -//}