[fix][client] fix incomingMessageSize and client memory usage is negative

[TakaHiR07]

Fixes #23622

Motivation

After testing for autoScaledReceiverQueueSizeEnabled config, found that the client memory usage and incomingMessageSize is negative.

This error result in two problem:

1. autoScaledReceiverQueueSize feature is not correct. The receive queue size is expanded based on wrong memory usage.
2. batchReceivePolicy feature is not correct. The MaxNumBytes config in batchReceivePolicy is judged by wrong incomingMessageSize.

By the way, batchReceivePolicy is default used in multiTopicConsumer since pulsar-2.9.4, while autoScaledReceiverQueueSize is a optional config in consumer.

The reason is because when enter ConsumerImpl#notifyPendingReceivedCallback, the message would directly pass to pendingReceive request. Then consumerImpl just decrease the incomingMessageSize, but not increase. So the value become negative

Modifications

fix the error case that only do decrease the size, but not increase.

Verifying this change

• Make sure that the change passes the CI checks.

Documentation

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

[lhotari]

LGTM, great work @TakaHiR07

[dao-jun]

Nice catch, good work

[codecov-commenter]

Codecov Report

All modified and coverable lines are covered by tests ✅

Project coverage is 74.35%. Comparing base (bbc6224) to head (7d79851).
Report is 743 commits behind head on master.

Additional details and impacted files

@@             Coverage Diff              @@
##             master   #23624      +/-   ##
============================================
+ Coverage     73.57%   74.35%   +0.78%     
- Complexity    32624    34970    +2346     
============================================
  Files          1877     1944      +67     
  Lines        139502   147140    +7638     
  Branches      15299    16224     +925     
============================================
+ Hits         102638   109409    +6771     
- Misses        28908    29282     +374     
- Partials       7956     8449     +493     

Flag	Coverage Δ
inttests	27.65% <100.00%> (+3.07%)	⬆️
systests	24.37% <100.00%> (+0.04%)	⬆️
unittests	73.74% <100.00%> (+0.90%)	⬆️

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

Files with missing lines	Coverage Δ
...va/org/apache/pulsar/client/impl/ConsumerBase.java	75.29% <100.00%> (+1.17%)	⬆️
...va/org/apache/pulsar/client/impl/ConsumerImpl.java	80.32% <ø> (+2.75%)	⬆️

... and 656 files with indirect coverage changes

---- 🚨 Try these New Features:

• Flaky Tests Detection - Detect and resolve failed and flaky tests
• JS Bundle Analysis - Avoid shipping oversized bundles