Hi all, I have created a draft for KIP-138: Change punctuate semantics <https://cwiki.apache.org/confluence/display/KAFKA/KIP-138%3A+Change+punctuate+semantics> .
Appreciating there can be different views on system-time vs event-time semantics for punctuation depending on use-case and the importance of backwards compatibility of any such change, I've left it quite open and hope to fill in more info as the discussion progresses. Thanks, Michal