You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by da...@apache.org on 2024/09/26 15:15:04 UTC
(kafka) branch KAFKA-17621 updated: a few more
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 <dj...@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));
}