KIP-150 — Kafka-Streams Cogroup

Accepted Kafka 2.5 Streams

KIP-150 introduces the `CogroupedKStream` API to the Kafka Streams DSL, allowing multiple input streams to be co-grouped and aggregated into a single KTable using a single shared state store per key space. Without co-grouping, combining N streams into a single aggregate requires N intermediate KTables each with its own state store plus a chain of outer joins, creating high state amplification and complex topologies.

Details