Hello all, I would like to start the voting processing on the following KIP, to allow users control when a task can be processed based on its buffered records, and how the stream time of a task be advanced.
https://cwiki.apache.org/confluence/display/KAFKA/KIP- 353%3A+Improve+Kafka+Streams+Timestamp+Synchronization Thanks, -- Guozhang