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
| Author | Richard Yu |
| Status | Accepted |
| Kafka Version | 2.6 |
| JIRA | KAFKA-12508 |
| Wiki | View on Apache Wiki |
| Created | 2020-01-11 |
| Last Modified | 2021-03-24 |
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.