[
https://issues.apache.org/jira/browse/KAFKA-13824?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-13824:
----------------------------------
Description:
We pass in the {{Time}} object in the StreamThread, which is used to measure
various metrics so that we can mock the time in tests. We should extend this to
lower-level metrics, more specifically:
* KafkaStreams (instance-level): already done.
* StreamThread (thread-level): already done, in runtime passed through from
instance.
* ProcessingContext (task-level).
* MeteredStore (store-level).
* StreamTask (task-level).
* ProcessorNode (processor-node-level): only a few processors that need to
expose this level latency would need to have the {{Time}} object passed through.
> Pass time object from constructor so that we can mock it if needed
> ------------------------------------------------------------------
>
> Key: KAFKA-13824
> URL: https://issues.apache.org/jira/browse/KAFKA-13824
> Project: Kafka
> Issue Type: Improvement
> Reporter: Hao Li
> Priority: Minor
> Labels: test
>
> We pass in the {{Time}} object in the StreamThread, which is used to measure
> various metrics so that we can mock the time in tests. We should extend this
> to lower-level metrics, more specifically:
> * KafkaStreams (instance-level): already done.
> * StreamThread (thread-level): already done, in runtime passed through from
> instance.
> * ProcessingContext (task-level).
> * MeteredStore (store-level).
> * StreamTask (task-level).
> * ProcessorNode (processor-node-level): only a few processors that need to
> expose this level latency would need to have the {{Time}} object passed
> through.
--
This message was sent by Atlassian Jira
(v8.20.7#820007)
