[fix][client] The partitionedProducer maxPendingMessages always is 0

[shibd]

Motivation

After #13344, the default value of maxPendingMessages and maxPendingMessagesAcrossPartitions change to 0.

When creating a producer with the partitioned topic, setting one of the above configurations doesn't take effect; the actual value is always 0.

Because here have a minimum judgment.

pulsar/pulsar-client/src/main/java/org/apache/pulsar/client/impl/PartitionedProducerImpl.java

Lines 86 to 89 in 92448d5

	// MaxPendingMessagesAcrossPartitions doesn't support partial partition such as SinglePartition correctly
	int maxPendingMessages = Math.min(conf.getMaxPendingMessages(),
	conf.getMaxPendingMessagesAcrossPartitions() / numPartitions);
	conf.setMaxPendingMessages(maxPendingMessages);

Modifications

• When setting one of the values, use it directly. Only perform the min check when both values are not zero.

Verifying this change

• Add PartitionedProducerImplTest.testMaxPendingQueueSize to cover this logic.
• Add testProducerQueueFullBlockingWithPartitionedTopic test to cover blockQueueFullWithPartitiond case.

Documentation

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

Matching PR in forked repository

PR in forked repository:

[lhotari]

LGTM, good catch