[ 
https://issues.apache.org/jira/browse/KAFKA-15981?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Jeff Kim updated KAFKA-15981:
-----------------------------
    Summary: update Group size only when groups size changes  (was: only record 
Group state metrics once per group during load)

> update Group size only when groups size changes
> -----------------------------------------------
>
>                 Key: KAFKA-15981
>                 URL: https://issues.apache.org/jira/browse/KAFKA-15981
>             Project: Kafka
>          Issue Type: Sub-task
>            Reporter: Jeff Kim
>            Assignee: Jeff Kim
>            Priority: Major
>
> Currently, we increment generic group metrics whenever we create a new 
> GenericGroup object while we load the partition. This is incorrect as the 
> partition may contain several records for the same group if in the active 
> segment or if the segment has not yet been compacted. Same applies to 
> removing groups; we can possibly have group tombstone preceding a group 
> metadata record.
> Instead, increment the metrics for each group we successfully loaded.
> Also applies to ConsumerGroup.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

Reply via email to