kotka-streams-extensions/dev.adamko.kotka.extensions/consumedAs

consumedAs

fun <Key, Val> consumedAs(name: String? = null, keySerde: Serde<Key>? = null, valueSerde: Serde<Val>? = null, resetPolicy: Topology.AutoOffsetReset? = null, timestampExtractor: TimestampExtractor? = null): Consumed<Key, Val>

See also