Skip to content

Commit

Permalink
MINOR: Fix group metadata loading log (apache#15368)
Browse files Browse the repository at this point in the history
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 <[email protected]>, Bruno Cadonna <[email protected]>
  • Loading branch information
dajac authored Feb 15, 2024
1 parent d378ad3 commit 5edf523
Showing 1 changed file with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -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()
);
}
Expand Down

0 comments on commit 5edf523

Please sign in to comment.