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

KotkaSerdeModule

class KotkaSerdeModule(val mapper: StringFormat)

Constructors

KotkaSerdeModule

constructor(mapper: StringFormat)

Functions

inline fun <Key, Val> groupedAs(name: String, keySerde: Serde<Key>? = mapper.serde(), valueSerde: Serde<Val>? = mapper.serde()): Grouped<Key, Val>

inline fun <Key, Val, V_other> joinedAs(name: String, keySerde: Serde<Key> = mapper.serde(), valueSerde: Serde<Val> = mapper.serde(), otherValueSerde: Serde<V_other>? = mapper.serde()): Joined<Key, Val, V_other>

inline fun <Key, Val, Store : StateStore> materializedAs(name: String, keySerde: Serde<Key> = mapper.serde(), valueSerde: Serde<Val> = mapper.serde()): Materialized<Key, Val, Store>

inline fun <Key, Val> producedAs(name: String, keySerde: Serde<Key> = mapper.serde(), valueSerde: Serde<Val> = mapper.serde()): Produced<Key, Val>

repartitionedAs

inline fun <Key, Val> repartitionedAs(name: String, keySerde: Serde<Key> = mapper.serde(), valueSerde: Serde<Val> = mapper.serde()): Repartitioned<Key, Val>

Properties

val mapper: StringFormat