lucasbru commented on code in PR #18809:
URL: https://github.com/apache/kafka/pull/18809#discussion_r1958380749
##########
group-coordinator/src/main/java/org/apache/kafka/coordinator/group/metrics/GroupCoordinatorMetricsShard.java:
##########
@@ -82,7 +82,7 @@ public TimelineGaugeCounter(TimelineLong timelineLong,
AtomicLong atomicLong) {
/**
* Streams group size gauge counters keyed by the metric name.
*/
- private final Map<StreamsGroupState, TimelineGaugeCounter>
streamsGroupGauges;
+ private volatile Map<StreamsGroupState, Long> streamsGroupGauges;
Review Comment:
I was mostly following a change from the consumer groups here, but indeed it
looks more lightweight
--
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]
