[fix][client] Exit when no msg to consume if time reaches the limit (a…

…pache#21622) Co-authored-by: Jiwe Guo <[email protected]>
streamnative · Dec 5, 2023 · fe2d6d3 · fe2d6d3
1 parent 5531524
commit fe2d6d3
Showing 1 changed file with 8 additions and 0 deletions.
diff --git a/pulsar-testclient/src/main/java/org/apache/pulsar/testclient/PerformanceConsumer.java b/pulsar-testclient/src/main/java/org/apache/pulsar/testclient/PerformanceConsumer.java
@@ -505,6 +505,14 @@ public static void main(String[] args) throws Exception {
 
             reportHistogram.reset();
             oldTime = now;
+
+            if (arguments.testTime > 0) {
+                if (now > testEndTime) {
+                    log.info("------------------- DONE -----------------------");
+                    PerfClientUtils.exit(0);
+                    thread.interrupt();
+                }
+            }
         }
 
         pulsarClient.close();