[fix][test] flaky test testCanRecoverConsumptionWhenLiftMaxUnAckedMessagesRestriction

[labuladong]

Fixes #18617

Modifications

The reason for Awaitility timeout:

pulsar/pulsar-broker/src/test/java/org/apache/pulsar/client/impl/KeySharedSubscriptionTest.java

Lines 142 to 155 in 3df506d

	Producer<byte[]> producer = pulsarClient.newProducer()
	.topic(topic)
	.enableBatching(true)
	.batchingMaxPublishDelay(1, TimeUnit.MILLISECONDS)
	// We chose 9 because the maximum unacked message is 10
	.batchingMaxMessages(9)
	.create();
	for (int i = 0; i < totalMsg; i++) {
	producer.sendAsync(UUID.randomUUID().toString()
	.getBytes(StandardCharsets.UTF_8))
	.thenAccept(pubMessages::add);
	}

The producer didn't set a key for msg, so even if there are 3 key_shared consumers, there is only 1 consumer to receive messages.

Then this consumer will sync receive and sync ack 1000 messages in 10 - 5 = 5 seconds, a little hurry:

pulsar/pulsar-broker/src/test/java/org/apache/pulsar/client/impl/KeySharedSubscriptionTest.java

Lines 172 to 177 in 3df506d

	// Wait for all consumers to continue receiving messages.
	Awaitility.await()
	.pollDelay(5, TimeUnit.SECONDS)
	.until(() ->
	(System.currentTimeMillis() - lastActiveTime.get()) > TimeUnit.SECONDS.toMillis(5));

Solution:

1. Construct keys for messages, and ensure all 3 consumers can handle messages.

2. Give more time to wait for all consumers to handle messages.

Verifying this change

• Make sure that the change passes the CI checks.

Documentation

• doc
• doc-required
• doc-not-needed
• doc-complete

Matching PR in forked repository

PR in forked repository: labuladong#15

[codecov-commenter]

Codecov Report

Merging #18726 (a57c20a) into master (b36e012) will decrease coverage by 0.78%.
The diff coverage is n/a.

@@             Coverage Diff              @@
##             master   #18726      +/-   ##
============================================
- Coverage     47.74%   46.95%   -0.79%     
+ Complexity    10623    10552      -71     
============================================
  Files           703      703              
  Lines         68828    68828              
  Branches       7381     7381              
============================================
- Hits          32861    32319     -542     
- Misses        32307    32874     +567     
+ Partials       3660     3635      -25     

Flag	Coverage Δ
unittests	46.95% <ø> (-0.79%)	⬇️

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

Impacted Files	Coverage Δ
...pache/pulsar/broker/tools/GenerateDocsCommand.java	0.00% <0.00%> (-77.28%)	⬇️
.../apache/pulsar/utils/CmdGenerateDocumentation.java	0.00% <0.00%> (-76.93%)	⬇️
...ourcegroup/ResourceUsageTopicTransportManager.java	0.00% <0.00%> (-74.79%)	⬇️
...ava/org/apache/pulsar/broker/tools/BrokerTool.java	0.00% <0.00%> (-71.43%)	⬇️
...che/pulsar/broker/resourcegroup/ResourceGroup.java	28.76% <0.00%> (-40.07%)	⬇️
...sar/broker/resourcegroup/ResourceGroupService.java	37.77% <0.00%> (-35.87%)	⬇️
...ker/resourcegroup/ResourceGroupPublishLimiter.java	39.08% <0.00%> (-35.64%)	⬇️
...ulsar/utils/ConcurrentBitmapSortedLongPairSet.java	59.25% <0.00%> (-31.49%)	⬇️
...ava/org/apache/pulsar/utils/StatsOutputStream.java	70.90% <0.00%> (-29.10%)	⬇️
...pache/pulsar/utils/auth/tokens/TokensCliUtils.java	0.00% <0.00%> (-26.39%)	⬇️
... and 49 more

[labuladong]

/pulsarbot rerun-failure-checks

[labuladong]

/pulsarbot rerun-failure-checks

[labuladong]

/pulsarbot rerun-failure-checks

[labuladong]

/pulsarbot rerun-failure-checks

[labuladong]

/pulsarbot rerun-failure-checks

[liangyepianzhou]

LGTM

[labuladong]

This pr is ready to merge ^_^