Bruno Cadonna created KAFKA-9129:
------------------------------------
Summary: Add Thread ID to the InternalProcessorContext
Key: KAFKA-9129
URL: https://issues.apache.org/jira/browse/KAFKA-9129
Project: Kafka
Issue Type: Improvement
Components: streams
Reporter: Bruno Cadonna
When we added client metrics we had to move the {{StreamsMetricsImpl}} object
to the client level. That means that now instead of having one
{{StreamsMetricsImpl}} object per thread, we have now one per client. That also
means that we cannot store the thread ID in the {{StreamsMetricsImpl}} anymore.
Currently, we get the thread ID from {{Thread.currentThread().getName()}} when
we need to create a sensor. However, that is not robust against code
refactoring because we need to ensure that the thread that creates the sensor
is also the one that records the metrics. To be more flexible, we should expose
the ID of the thread that executes a processor in the
{{InternalProcessorContext}} like it already exposes the task ID.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
