[I] [Bug] in chunk message consumer, pendingChunkedMessageCount is not synced with count of entries present in chunkedMessagesMap [pulsar]

["programmerahul (via GitHub)" <gi...@apache.org>]

programmerahul opened a new issue, #26688:
URL: https://github.com/apache/pulsar/issues/26688

   ### Search before reporting
   
   - [x] I searched in the [issues](https://github.com/apache/pulsar/issues) and found nothing similar.
   
   
   ### Read release policy
   
   - [x] I understand that [unsupported versions](https://pulsar.apache.org/contribute/release-policy/#supported-versions) don't get bug fixes. I will attempt to reproduce the issue on a supported version of Pulsar client and Pulsar broker.
   
   
   ### User environment
   
   Broker, client version- 4
   OS : Mac Sequoia
   
   ### Issue Description
   
   When the chunked messages assembling is dropped due to out-of order delivery, or normal duplicate chunk, in that case the entires are removed from chunkedMessagesMap but this counter is not decremented pendingChunkedMessageCount. So eventually pendingChunkedMessageCount starts having values higher than the entries in this map chunkedMessagesMap. 
   
   
   ### Error messages
   
   ```text
   this cause unnecessary eviction of message by calling removeOldestPendingChunkedMessage, when actual count is still less
   ```
   
   ### Reproducing the issue
   
   if the message are being delivered out-of-order, or duplicate messages, then the pendingChunkedMessageCount and count of entries in chunkedMessagesMap diverge
   
   ### Additional information
   
   _No response_
   
   ### Are you willing to submit a PR?
   
   - [ ] I'm willing to submit a PR!


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: commits-unsubscribe@pulsar.apache.org.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

Re: [I] [Bug] in chunk message consumer, pendingChunkedMessageCount is not synced with count of entries present in chunkedMessagesMap [pulsar]

["Abdellox (via GitHub)" <gi...@apache.org>]

Abdellox commented on issue #26688:
URL: https://github.com/apache/pulsar/issues/26688#issuecomment-5778720491

   Thanks for opening this! I'd like to help investigate.
   
   Could you share:
   - Steps to reproduce
   - Expected vs actual behavior
   - Environment details
   
   I'll take a look at the code and see if I can help.


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: commits-unsubscribe@pulsar.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

Re: [I] [Bug] in chunk message consumer, pendingChunkedMessageCount is not synced with count of entries present in chunkedMessagesMap [pulsar]

["programmerahul (via GitHub)" <gi...@apache.org>]

programmerahul commented on issue #26688:
URL: https://github.com/apache/pulsar/issues/26688#issuecomment-5781515395

   Thanks @Abdellox, but I have already raised a PR for this issue.


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: commits-unsubscribe@pulsar.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org