consumer

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>