KIP-655 — Windowed Distinct Operation for Kafka Streams API

Accepted Streams

Adds a windowed distinct() operation to the Kafka Streams DSL that deduplicates records within a configurable time window using a state store. Applications consuming topics written with at-least-once semantics have no native deduplication primitive, forcing teams to implement custom stateful processors that are error-prone and difficult to reuse.

Details