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