vvcephei commented on code in PR #11993:
URL: https://github.com/apache/kafka/pull/11993#discussion_r849705530
##########
streams/test-utils/src/main/java/org/apache/kafka/streams/processor/api/MockProcessorContext.java:
##########
@@ -336,6 +344,14 @@ public void setRecordMetadata(final String topic,
recordMetadata = new MockRecordMetadata(topic, partition, offset);
}
+ public void setCurrentSystemTimeMs(final long currentSystemTimeMs) {
+ this.currentSystemTimeMs = currentSystemTimeMs;
+ }
+
+ public void setCurrentStreamTimeMs(final long currentStreamTimeMs) {
+ this.currentStreamTimeMs = currentStreamTimeMs;
+ }
Review Comment:
Ok, I think I remember this now. The KIP that added those time APIs forgot
to add them to the new Processor API and only did the old API. I think it got
missed because both KIPs were going in parallel.
Can you dig up that KIP and just notify the vote thread of it that we need
to amend the KIP to address this oversight? It shouldn't require a new vote or
anything, but we should update the KIP.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
