[fix][cli] Fix timeout behavior of reader perf

[labuladong]

Fixes #17824

Modifications

Add a timer to handle timeout exit.

Verifying this change

• Make sure that the change passes the CI checks.

This change is already covered by existing tests.

Does this pull request potentially affect one of the following parts:

• Dependencies (add or upgrade a dependency)
• The public API
• The schema
• The default values of configurations
• The binary protocol
• The REST endpoints
• The admin CLI options
• Anything that affects deployment

Documentation

• doc-required
  (Your PR needs to update docs and you will update later)

• doc-not-needed
  (Please explain why)

• doc
  (Your PR contains doc changes)

• doc-complete
  (Docs have been already added)

Matching PR in forked repository

PR in forked repository: labuladong#1

[labuladong]

In the listener, all the actions are concurrent safe, so I just add a timer to handle timeout.

@mattisonchao @andFrasbeni PTAL

[labuladong]

@andrasbeni @mattisonchao Could you please review this pr? Thanks

[andrasbeni]

This fix looks good to me

[labuladong]

/pulsarbot rerun-failure-checks

[tisonkun]

You may change the PR title as [fix][test] ....

[labuladong]

But it's about the perf tool, not a test.

[tisonkun]

@labuladong I think we currently accept the following scope, you may choose one or propose changes:

pulsar/.github/workflows/ci-semantic-pull-request.yml

Lines 50 to 81 in 574f784

	# Scope abbreviation comments:
	# cli -> command line interface
	# fn -> Pulasr Functions
	# io -> Pulsar Connectors
	# offload -> tiered storage
	# sec -> security
	# sql -> Pulsar Trino Plugin
	# txn -> transaction
	# ws -> websocket
	scopes: |
	admin
	broker
	build
	ci
	cli
	client
	doc
	fn
	io
	meta
	misc
	monitor
	offload
	proxy
	schema
	sec
	site
	sql
	storage
	test
	txn
	ws

[labuladong]

I think this pr belongs to cli scope, thanks. @tisonkun

[codecov-commenter]

Codecov Report

Merging #17882 (4754b3f) into master (0866c3a) will increase coverage by 10.75%.
The diff coverage is n/a.

@@              Coverage Diff              @@
##             master   #17882       +/-   ##
=============================================
+ Coverage     38.97%   49.72%   +10.75%     
+ Complexity     8311     7021     -1290     
=============================================
  Files           683      400      -283     
  Lines         67325    43612    -23713     
  Branches       7217     4477     -2740     
=============================================
- Hits          26239    21686     -4553     
+ Misses        38079    19501    -18578     
+ Partials       3007     2425      -582     

Flag	Coverage Δ
unittests	49.72% <ø> (+10.75%)	⬆️

Flags with carried forward coverage won't be shown. Click here to find out more.

Impacted Files	Coverage Δ
...java/org/apache/pulsar/proxy/stats/TopicStats.java	58.82% <0.00%> (-41.18%)	⬇️
...lsar/broker/loadbalance/impl/ThresholdShedder.java	3.26% <0.00%> (-39.87%)	⬇️
...ersistentStickyKeyDispatcherMultipleConsumers.java	44.71% <0.00%> (-12.99%)	⬇️
...e/pulsar/broker/service/EntryBatchIndexesAcks.java	82.14% <0.00%> (-10.72%)	⬇️
...ce/schema/validator/StructSchemaDataValidator.java	52.38% <0.00%> (-9.53%)	⬇️
...org/apache/pulsar/broker/loadbalance/LoadData.java	58.33% <0.00%> (-8.34%)	⬇️
...g/apache/pulsar/broker/service/StreamingStats.java	75.67% <0.00%> (-8.11%)	⬇️
.../pulsar/broker/service/PublishRateLimiterImpl.java	58.00% <0.00%> (-6.00%)	⬇️
...ava/org/apache/pulsar/utils/StatsOutputStream.java	65.45% <0.00%> (-5.46%)	⬇️
...oker/service/schema/SchemaRegistryServiceImpl.java	59.15% <0.00%> (-5.11%)	⬇️
... and 318 more

[tisonkun]

/pulsarbot rerun-failure-checks

[labuladong]

/pulsarbot rerun-failure-checks

[labuladong]

/pulsarbot rerun-failure-checks

[labuladong]

Could you please merge this pr? @codelipenghui