philipnee commented on code in PR #15210:
URL: https://github.com/apache/kafka/pull/15210#discussion_r1457711259
##########
clients/src/main/java/org/apache/kafka/clients/consumer/internals/ConsumerCoordinator.java:
##########
@@ -1547,6 +1553,29 @@ public String toString() {
}
}
+ private class ConsumerCoordinatorMetrics {
Review Comment:
I split the implementation into two classes because there's no need to pass
the ref of this entire object to the request manager just for the commitSensor
(see addCommitSensor method). Instead, I think it would be a lot easier to
pass the Metrics object to the manager and create their own sensors
(essentially these metrics objects just hold a bunch of sensors referenced from
Metrics).
--
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]
