aggregate

fun <K, inV, outV> KGroupedStream<K, inV>.aggregate(    initializer: Initializer<outV>,     materialized: Materialized<K, outV, KeyValueStore<Bytes, ByteArray>>,     aggregator: Aggregator<K, inV, outV>): KTable<K, outV>
fun <K, inV, outV> KGroupedStream<K, inV>.aggregate(    name: String,     materialized: Materialized<K, outV, KeyValueStore<Bytes, ByteArray>>,     initializer: Initializer<outV>,     aggregator: Aggregator<K, inV, outV>): KTable<K, outV>

See also