You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@pulsar.apache.org by GitBox <gi...@apache.org> on 2019/03/08 01:08:41 UTC

[GitHub] [pulsar] merlimat opened a new pull request #3787: Fixed increasing consumer permits after ack dedup operation

merlimat opened a new pull request #3787: Fixed increasing consumer permits after ack dedup operation
URL: https://github.com/apache/pulsar/pull/3787
 
 
   ### Motivation
   
   With the delayed acknowledgment tracker, the deduping logic is used to ignore messages that are being resent from broker after reconnection but for which the application has already acked. 
   These acks are tracked in client library and sent later in batches (default 100ms). 
   
   When we ignore messages as dups for the above logic, we must always increase the available permits, otherwise the count will be off. In cases where the receiver queue size is small, that could lead to a consumer getting stuck, since it will not advertise more permits to the broker.
   
   

----------------------------------------------------------------
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.
 
For queries about this service, please contact Infrastructure at:
users@infra.apache.org


With regards,
Apache Git Services