Don't understand the second check? Why must the record-time (or window-end-time) be less-or-equal to current stream-time? For record-time, this should be true all the time, but for window-end time, I don't think this is true -- why do we want to fail for this case?
[ Full content available at: https://github.com/apache/kafka/pull/5567 ] This message was relayed via gitbox.apache.org for [email protected]
