[GitHub] [kafka] guozhangwang commented on a change in pull request #10170: KAFKA-12323: Set timestamp in record context when punctuate

guozhangwang commented on a change in pull request #10170: URL: https://github.com/apache/kafka/pull/10170#discussion_r581618213 ## File path: streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamThreadTest.java ## @@ -1874,6 +1873,85 @@ public void

[GitHub] [kafka] guozhangwang commented on a change in pull request #10170: KAFKA-12323: Set timestamp in record context when punctuate

guozhangwang commented on a change in pull request #10170: URL: https://github.com/apache/kafka/pull/10170#discussion_r581615084 ## File path: streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamThreadTest.java ## @@ -1805,18 +1806,16 @@ public void

[GitHub] [kafka] guozhangwang commented on a change in pull request #10170: KAFKA-12323: Set timestamp in record context when punctuate

guozhangwang commented on a change in pull request #10170: URL: https://github.com/apache/kafka/pull/10170#discussion_r580793422 ## File path: streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamTask.java ## @@ -792,7 +790,16 @@ public void