[jira] [Created] (KAFKA-9129) Add Thread ID to the InternalProcessorContext

["Bruno Cadonna (Jira)" <ji...@apache.org>]

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)