(kafka) branch KAFKA-17621 updated: a few more

[dajac]

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

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


The following commit(s) were added to refs/heads/KAFKA-17621 by this push:
     new 3c854e8e084 a few more
3c854e8e084 is described below

commit 3c854e8e08479e7d4ebc1ba2d4e47a930f23ccd5
Author: David Jacot <dja...@confluent.io>
AuthorDate: Thu Sep 26 15:14:41 2024 +0000

    a few more
---
 .../kafka/coordinator/group/GroupMetadataManager.java     | 15 +++++++++++----
 1 file changed, 11 insertions(+), 4 deletions(-)

diff --git 
a/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java
 
b/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java
index 84eeee6462d..ec741a6cfda 100644
--- 
a/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java
+++ 
b/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java
@@ -2549,8 +2549,13 @@ public class GroupMetadataManager {
                 assignmentResultBuilder.build();
             long assignorTimeMs = time.milliseconds() - startTimeMs;
 
-            log.info("[GroupId {}] Computed a new target assignment for epoch 
{} with '{}' assignor in {}ms: {}.",
-                group.groupId(), groupEpoch, preferredServerAssignor, 
assignorTimeMs, assignmentResult.targetAssignment());
+            if (log.isDebugEnabled()) {
+                log.debug("[GroupId {}] Computed a new target assignment for 
epoch {} with '{}' assignor in {}ms: {}.",
+                    group.groupId(), groupEpoch, preferredServerAssignor, 
assignorTimeMs, assignmentResult.targetAssignment());
+            } else {
+                log.info("[GroupId {}] Computed a new target assignment for 
epoch {} with '{}' assignor in {}ms.",
+                    group.groupId(), groupEpoch, preferredServerAssignor, 
assignorTimeMs);
+            }
 
             records.addAll(assignmentResult.records());
 
@@ -2747,8 +2752,10 @@ public class GroupMetadataManager {
             );
 
             if (!subscriptionMetadata.equals(group.subscriptionMetadata())) {
-                log.info("[GroupId {}] Computed new subscription metadata: 
{}.",
-                    group.groupId(), subscriptionMetadata);
+                if (log.isDebugEnabled()) {
+                    log.debug("[GroupId {}] Computed new subscription 
metadata: {}.",
+                        group.groupId(), subscriptionMetadata);
+                }
                 
records.add(newConsumerGroupSubscriptionMetadataRecord(group.groupId(), 
subscriptionMetadata));
             }