conduktor.io ↗

KIP-557 — Add emit on change support for Kafka Streams

Accepted Kafka 2.6 Streams

Adds an `emit-on-change` processing mode to Kafka Streams aggregations so that downstream records are only forwarded when the aggregated value actually changes, suppressing redundant identical updates. Currently, Kafka Streams only supports `emit-on-update` (always forward) and `emit-on-window-close` (suppress until window closes), with no way to deduplicate identical successive aggregation results.

Details

AuthorRichard Yu
StatusAccepted
Kafka Version2.6
JIRAKAFKA-12508
WikiView on Apache Wiki
Created2020-01-11
Last Modified2021-03-24
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.