rohitrmd commented on a change in pull request #9744:
URL: https://github.com/apache/kafka/pull/9744#discussion_r587996458
##########
File path:
streams/test-utils/src/main/java/org/apache/kafka/streams/processor/MockProcessorContext.java
##########
@@ -353,11 +371,19 @@ public void setHeaders(final Headers headers) {
* The context exposes this metadata for use in the processor. Normally,
they are set by the Kafka Streams framework,
* 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
+ * @param recordTimestamp A record timestamp
*/
@SuppressWarnings({"WeakerAccess", "unused"})
- public void setTimestamp(final long timestamp) {
- this.timestamp = timestamp;
+ public void setRecordTimestamp(final long recordTimestamp) {
+ this.recordTimestamp = recordTimestamp;
+ }
+
+ public void setCurrentSystemTimeMs(final long currentSystemTimeMs) {
+ this.currentSystemTimeMs = currentSystemTimeMs;
+ }
+
+ public void setCurrentStreamTimeMs(final long currentStreamTimeMs) {
+ this.currentStreamTimeMs = currentStreamTimeMs;
Review comment:
@mjsax added the method setTimestamp back which sets record timestamp
and added Deprecated annotation.
----------------------------------------------------------------
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:
us...@infra.apache.org
