cadonna commented on a change in pull request #9098:
URL: https://github.com/apache/kafka/pull/9098#discussion_r463578816
##########
File path:
streams/test-utils/src/main/java/org/apache/kafka/streams/processor/MockProcessorContext.java
##########
@@ -227,7 +228,8 @@ public MockProcessorContext(final Properties config, final
TaskId taskId, final
this.metrics = new StreamsMetricsImpl(
new Metrics(metricConfig),
threadId,
-
streamsConfig.getString(StreamsConfig.BUILT_IN_METRICS_VERSION_CONFIG)
+
streamsConfig.getString(StreamsConfig.BUILT_IN_METRICS_VERSION_CONFIG),
+ Time.SYSTEM
Review comment:
I would prefer to postpone that, because currently it is not strictly
needed and the time is only used in the RocksDB recording trigger that records
only internal RocksDB metrics. I do not see how exposing time would be useful
for users during testing. If anybody complains, we can still do it in a future
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.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
