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() ); }