kotka-streams-framework/dev.adamko.kotka.topicdata/KeyValueSerdes

KeyValueSerdes

open class KeyValueSerdes<K, V>(val keySerde: Serde<K>, val valueSerde: Serde<V>)

A pair of Serdes - one for the Key, another for the Value.

Constructors

constructor(keySerde: Serde<K>, valueSerde: Serde<V>)

Types

object Companion

Functions

fun consumer(name: String? = null, keySerde: Serde<K>? = this.keySerde, valueSerde: Serde<V>? = this.valueSerde, resetPolicy: Topology.AutoOffsetReset? = null, timestampExtractor: TimestampExtractor? = null): Consumed<K, V>

fun grouper(name: String? = null, keySerde: Serde<K>? = this.keySerde, valueSerde: Serde<V>? = this.valueSerde): Grouped<K, V>

fun <otherV> joiner(name: String? = null, keySerde: Serde<K>? = this.keySerde, valueSerde: Serde<V>? = this.valueSerde, otherValueSerde: Serde<otherV>?): Joined<K, V, otherV>

fun producer(name: String? = null, keySerde: Serde<K>? = this.keySerde, valueSerde: Serde<V>? = this.valueSerde, partitioner: StreamPartitioner<K, V>? = null): Produced<K, V>

fun repartitioner(name: String? = null, keySerde: Serde<K>? = this.keySerde, valueSerde: Serde<V>? = this.valueSerde, numberOfPartitions: Int? = null, partitioner: StreamPartitioner<K, V>? = null): Repartitioned<K, V>

Properties

open val keySerde: Serde<K>

open val valueSerde: Serde<V>