[Bug] PerformanceConsumer does not stop at numMessages messages received

[andrasbeni]

Search before asking

• [X] I searched in the issues and found nothing similar.

Version

master branch, 8b771a6a528d85bbec6a3d791356a9ab6e9e5ea3

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?

• [X] I'm willing to submit a PR!