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

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

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

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

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

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

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

mjsax commented on a change in pull request #10170: URL: https://github.com/apache/kafka/pull/10170#discussion_r580546901 ## File path: streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamThreadTest.java ## @@ -1874,6 +1873,66 @@ public void close() {}

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

mjsax commented on a change in pull request #10170: URL: https://github.com/apache/kafka/pull/10170#discussion_r580546373 ## File path: streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamThreadTest.java ## @@ -1874,6 +1873,66 @@ public void close() {}

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

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