mjsax commented on a change in pull request #9744:
URL: https://github.com/apache/kafka/pull/9744#discussion_r590766321
##########
File path:
streams/src/main/java/org/apache/kafka/streams/processor/ProcessorContext.java
##########
@@ -289,4 +291,33 @@ Cancellable schedule(final Duration interval,
*/
Map<String, Object> appConfigsWithPrefix(final String prefix);
+ /**
+ * Return the current system timestamp (also called wall-clock time) in
milliseconds.
+ *
+ * <p>
+ * Note: this method returns the internally cached system timestamp from
the Kafka Stream runtime.
+ * Thus, it may return a different value compared to {@code
System.currentTimeMillis()}
Review comment:
```suggestion
* Thus, it may return a different value compared to {@code
System.currentTimeMillis()}.
```
##########
File path:
streams/src/main/java/org/apache/kafka/streams/processor/ProcessorContext.java
##########
@@ -289,4 +291,33 @@ Cancellable schedule(final Duration interval,
*/
Map<String, Object> appConfigsWithPrefix(final String prefix);
+ /**
+ * Return the current system timestamp (also called wall-clock time) in
milliseconds.
+ *
+ * <p>
+ * Note: this method returns the internally cached system timestamp from
the Kafka Stream runtime.
+ * Thus, it may return a different value compared to {@code
System.currentTimeMillis()}
+ * <p>
Review comment:
```suggestion
```
##########
File path:
streams/test-utils/src/main/java/org/apache/kafka/streams/processor/MockProcessorContext.java
##########
@@ -354,10 +372,31 @@ public void setHeaders(final Headers headers) {
* but for the purpose of driving unit tests, you can set it directly.
Setting this attribute doesn't affect the others.
*
* @param timestamp A record timestamp
+ * @deprecated Use {@link MockProcessorContext#setRecordTimestamp(long)}
instead.
Review comment:
```suggestion
* @deprecated Since 3.0.0; use {@link
MockProcessorContext#setRecordTimestamp(long)} instead.
```
----------------------------------------------------------------
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.
For queries about this service, please contact Infrastructure at:
[email protected]
