kotka-streams-kotlinx-serialization/dev.adamko.kotka.kxs

Package-level declarations

Types

Link copied to clipboard
class KotkaSerdeModule(val mapper: StringFormat)

Functions

Link copied to clipboard
inline fun <T> BinaryFormat.kafkaDeserializer(serializer: KSerializer<T> = serializersModule.serializer()): Deserializer<T>
inline fun <T> StringFormat.kafkaDeserializer(serializer: KSerializer<T> = serializersModule.serializer()): Deserializer<T>
Link copied to clipboard
inline fun <T> BinaryFormat.kafkaSerializer(serializer: KSerializer<T> = serializersModule.serializer()): Serializer<T>
inline fun <T> StringFormat.kafkaSerializer(serializer: KSerializer<T> = serializersModule.serializer()): Serializer<T>
Link copied to clipboard
inline fun <K, V> BinaryFormat.keyValueSerdes(keySerializer: KSerializer<K> = serializersModule.serializer(), valueSerializer: KSerializer<V> = serializersModule.serializer()): <Error class: unknown class><K, V>
inline fun <K, V> StringFormat.keyValueSerdes(keySerializer: KSerializer<K> = serializersModule.serializer(), valueSerializer: KSerializer<V> = serializersModule.serializer()): <Error class: unknown class><K, V>
Link copied to clipboard
inline fun <T> BinaryFormat.serde(serializer: KSerializer<T> = serializersModule.serializer()): Serde<T>
inline fun <T> StringFormat.serde(serializer: KSerializer<T> = serializersModule.serializer()): Serde<T>