[Bug] PerformanceConsumer does not stop at numMessages messages received

[andrasbeni]

Search before asking

• I searched in the issues and found nothing similar.

Version

master branch, 8b771a6

Minimal reproduce step

start ./pulsar-perf consume -u pulsar://localhost:6650 -m 100 topic
run ./pulsar-perf produce -u pulsar://localhost:6650 -m 110 topic in parallel

What did you expect to see?

pulsar-perf consume should have stopped after receiving 100 messages.

What did you see instead?

pulsar-perf consume did not stop even after 110 messages.

Anything else?

the field numMessages, that stores the value of the flag -m is never used.

Are you willing to submit a PR?

• I'm willing to submit a PR!