Merge remote-tracking branch 'origin/kip-932' into AKCORE-253

confluentinc · Jul 9, 2024 · 30a9ce8 · 30a9ce8
2 parents 97c1fb7 + dfcf22c
commit 30a9ce8
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/tools/src/main/java/org/apache/kafka/tools/ShareConsumerPerformance.java b/tools/src/main/java/org/apache/kafka/tools/ShareConsumerPerformance.java
@@ -73,6 +73,7 @@ public static void main(String[] args) {
             Map<MetricName, ? extends Metric> metrics = null;
             if (options.printMetrics())
                 metrics = shareConsumer.metrics();
+            shareConsumer.commitAsync();
             shareConsumer.close();
 
             // print final stats