Hello, I'd like to start a discussion for KIP-655.
KIP-655: https://cwiki.apache.org/confluence/display/KAFKA/KIP-655%3A+Windowed+Distinct+Operation+for+Kafka+Streams+API
I also opened a proof-of-concept PR for you to experiment with the API: PR#9210: https://github.com/apache/kafka/pull/9210 Regards, Ivan Ponomarev
