bbejeck commented on code in PR #17820:
URL: https://github.com/apache/kafka/pull/17820#discussion_r1844573860
##########
streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/ThreadMetrics.java:
##########
@@ -290,6 +295,30 @@ public static void addThreadStartTimeMetric(final String
threadId,
);
}
+ public static void addThreadStateTelemetryMetric(final String threadId,
+ final StreamsMetricsImpl
streamsMetrics,
+ final Gauge<Integer>
threadStateProvider) {
+ streamsMetrics.addThreadLevelMutableMetric(
+ THREAD_STATE,
Review Comment:
Ack, I think I need to copy settings from someone this is a common occurance
with my PRs
--
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.
To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
