Skip to content

Commit

Permalink
[fix][client] Exit when no msg to consume if time reaches the limit (#…
Browse files Browse the repository at this point in the history
…21622)

Co-authored-by: Jiwe Guo <technoboy@apache.org>
  • Loading branch information
yaalsn and Technoboy- authored Dec 5, 2023
1 parent 5531524 commit fe2d6d3
Showing 1 changed file with 8 additions and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -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();
Expand Down

0 comments on commit fe2d6d3

Please # to comment.