[GitHub] [kafka] guozhangwang commented on a diff in pull request #12235: KAFKA-13945: add bytes/records consumed and produced metrics

guozhangwang commented on code in PR #12235: URL: https://github.com/apache/kafka/pull/12235#discussion_r889168252 ## streams/src/main/java/org/apache/kafka/streams/processor/internals/metrics/StreamsMetricsImpl.java: ## @@ -388,6 +401,40 @@ private String nodeSensorPrefix(final

[GitHub] [kafka] guozhangwang commented on a diff in pull request #12235: KAFKA-13945: add bytes/records consumed and produced metrics

guozhangwang commented on code in PR #12235: URL: https://github.com/apache/kafka/pull/12235#discussion_r887401929 ## streams/src/main/java/org/apache/kafka/streams/processor/internals/ClientUtils.java: ## @@ -166,4 +169,28 @@ public static String extractThreadId(final String f