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 String threadId,
final String taskId, fina
+ SENSOR_PREFIX_DELIMITER + SENSOR_NODE_LABEL +
SENSOR_PREFIX_DELIMITER + processorNodeName;
}
+ public Sensor topicLevelSensor(final String threadId,
+ final String taskId,
+ final String processorNodeName,
+ final String topicName,
Review Comment:
I cannot access the apache wiki atm (seems down temporarily) but just double
checking is topic name part of the tag in the KIP proposal as well? If not we
should update the wiki and the KIP thread.
--
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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
