diff --git a/app/src/main/java/org/astraea/app/performance/Performance.java b/app/src/main/java/org/astraea/app/performance/Performance.java index 1942c6398d..dfb6eafa7f 100644 --- a/app/src/main/java/org/astraea/app/performance/Performance.java +++ b/app/src/main/java/org/astraea/app/performance/Performance.java @@ -130,6 +130,8 @@ public static List execute(final Argument param) { () -> producerThreads.stream().allMatch(AbstractThread::closed), param.logInterval, List.of( + ReportFormat.CSVContentElement.create( + "size", () -> String.valueOf(sizes.get().sum())), ReportFormat.CSVContentElement.create( "max size", () -> String.valueOf(sizes.get().max().getAsLong())), ReportFormat.CSVContentElement.create(