[Bug][client] Consumer incomingMessageSize and client memory usage is negative

[TakaHiR07]

Search before asking

• I searched in the issues and found nothing similar.

Read release policy

• I understand that unsupported versions don't get bug fixes. I will attempt to reproduce the issue on a supported version of Pulsar client and Pulsar broker.

Version

master

Minimal reproduce step

use a simple demo to consume. Found that client memory usage is negative, and ConsumerBase#incomingMessagesSize is also negative.

Consumer<byte[]> consumer = client.newConsumer(Schema.BYTES)
                .topic("persistent://test/normal/test")
                .subscriptionInitialPosition(SubscriptionInitialPosition.Earliest)
                .subscriptionName("test")
                .subscriptionType(SubscriptionType.Shared)
                .autoScaledReceiverQueueSizeEnabled(true)
                .subscribe();

while (true) {
    Message msg = consumer.receive();
}

What did you expect to see?

incomingMessageSize and client memory usage should not be negative

What did you see instead?

incomingMessageSize and client memory usage is negative

Anything else?

No response

Are you willing to submit a PR?

• I'm willing to submit a PR!