lazzexus/Kafkatorio
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

rm unused class (moved to kotka-streams)

Browse source
This commit is contained in:
Adam 2022-02-20 12:21:46 +01:00
parent d5a55b423d
commit d3c7abff95
1 changed files with 0 additions and 50 deletions
Download patch file Download diff file Expand all files Collapse all files

50
modules/events-server/src/main/kotlin/dev/adamko/kafkatorio/processor/serdes/binaryFormat.kt
View file

@ -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()
//}