(kafka) branch trunk updated: MINOR: Log time spent cleaning share group state (#21278)

[dajac]

This is an automated email from the ASF dual-hosted git repository.

dajac pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/trunk by this push:
     new 00e0c582879 MINOR: Log time spent cleaning share group state (#21278)
00e0c582879 is described below

commit 00e0c5828797379a4b91b4abf058a9f7ac3f5b3d
Author: David Jacot <david.ja...@gmail.com>
AuthorDate: Sun Jan 11 15:39:46 2026 +0100

    MINOR: Log time spent cleaning share group state (#21278)
    
    This patch logs the time spent while cleaning the share group state on
    topic deletions.
    
    Reviewers: Andrew Schofield <aschofi...@confluent.io>
---
 .../org/apache/kafka/coordinator/group/GroupCoordinatorShard.java | 8 +++++++-
 1 file changed, 7 insertions(+), 1 deletion(-)

diff --git 
a/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorShard.java
 
b/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorShard.java
index 81651f5adf4..15eecf0fe7f 100644
--- 
a/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorShard.java
+++ 
b/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupCoordinatorShard.java
@@ -1038,7 +1038,13 @@ public class GroupCoordinatorShard implements 
CoordinatorShard<CoordinatorRecord
     public CoordinatorResult<Void, CoordinatorRecord> 
maybeCleanupShareGroupState(
         Set<Uuid> deletedTopicIds
     ) {
-        return 
groupMetadataManager.maybeCleanupShareGroupState(deletedTopicIds);
+        final long startTimeMs = time.milliseconds();
+        final var result = 
groupMetadataManager.maybeCleanupShareGroupState(deletedTopicIds);
+
+        log.info("Generated {} records in {} milliseconds while cleaning share 
group state for topics {}.",
+            result.records().size(), time.milliseconds() - startTimeMs, 
deletedTopicIds);
+
+        return result;
     }
 
     /**