Hello all, I would like to kick off a discussion 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 This is related to one of the root causes of out-of-ordering data in Kafka Streams. Any thoughts / comments on this topic is more than welcomed. Thanks, -- Guozhang
