From 5edf52359a99db801db91927c282af06b5ca4ee0 Mon Sep 17 00:00:00 2001 From: David Jacot Date: Thu, 15 Feb 2024 00:19:43 -0800 Subject: [PATCH] MINOR: Fix group metadata loading log (#15368) Spotted the following log: ``` [2024-02-14 09:59:30,103] INFO [GroupCoordinator id=1] Finished loading of metadata from 39 in __consumer_offsets-4ms with epoch 2 where 39ms was spent in the scheduler. Loaded 0 records which total to 0 bytes. (org.apache.kafka.coordinator.group.runtime.CoordinatorRuntime) ``` The partition and the time are incorrect. This patch fixes it. Reviewers: Jeff Kim , Bruno Cadonna --- .../kafka/coordinator/group/runtime/CoordinatorRuntime.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/runtime/CoordinatorRuntime.java b/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/runtime/CoordinatorRuntime.java index 5674273b12dab..b0be84c7a900b 100644 --- a/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/runtime/CoordinatorRuntime.java +++ b/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/runtime/CoordinatorRuntime.java @@ -1634,9 +1634,9 @@ public void scheduleLoadOperation( ctx.transitionTo(CoordinatorState.ACTIVE); if (summary != null) { runtimeMetrics.recordPartitionLoadSensor(summary.startTimeMs(), summary.endTimeMs()); - log.info("Finished loading of metadata from {} in {}ms with epoch {} where {}ms " + + log.info("Finished loading of metadata from {} with epoch {} in {}ms where {}ms " + "was spent in the scheduler. Loaded {} records which total to {} bytes.", - summary.endTimeMs() - summary.startTimeMs(), tp, partitionEpoch, + tp, partitionEpoch, summary.endTimeMs() - summary.startTimeMs(), summary.schedulerQueueTimeMs(), summary.numRecords(), summary.numBytes() ); }