Hello, Following a discussion on community slack channel, I would like to revive the discussion on the KIP-655, which is about adding a deduplication processor in kafka-streams.
https://cwiki.apache.org/confluence/display/KAFKA/KIP-655%3A+Windowed+Distinct+Operation+for+Kafka+Streams+API Even though the motivation is not quite the same as the initial one, I updated the KIP rather than creating a new one, as I believe the end goal is the same. Thanks, Ayoub
