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

KotkaSerdeModule

class KotkaSerdeModule(val mapper: StringFormat)

Constructors

Link copied to clipboard
constructor(mapper: StringFormat)

Functions

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

See Grouped.as

Link copied to clipboard
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>
Link copied to clipboard
inline fun <Key, Val, Store : StateStore> materializedAs(    name: String,     keySerde: Serde<Key> = mapper.serde(),     valueSerde: Serde<Val> = mapper.serde()): Materialized<Key, Val, Store>
Link copied to clipboard
inline fun <Key, Val> producedAs(    name: String,     keySerde: Serde<Key> = mapper.serde(),     valueSerde: Serde<Val> = mapper.serde()): Produced<Key, Val>
Link copied to clipboard
inline fun <Key, Val> repartitionedAs(    name: String,     keySerde: Serde<Key> = mapper.serde(),     valueSerde: Serde<Val> = mapper.serde()): Repartitioned<Key, Val>

Properties

Link copied to clipboard
val mapper: StringFormat