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

count

fun <K> KGroupedStream<K, *>.count(name: String? = null, materialized: Materialized<K, Long, KeyValueStore<Bytes, ByteArray>>? = null): KTable<K, Long>

See also