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 2022/05/25 03:27:55 UTC

[GitHub] [pulsar] merlimat commented on issue #15703: `receiver_queue_size` of 1 does not work; Shared consumers with receiver_queue_size=1 can "steal" messages that other consumers should receive

merlimat commented on issue #15703:
URL: https://github.com/apache/pulsar/issues/15703#issuecomment-1136684901

   @zbentley The pre-fetching is tied to the `receive()` calls and not the acknowledgements. 
   
   As long as you keep calling receive, you are making more space in the queue and the client library will ask for more messages to the broker. In this case, it is expected to be a race for consumer-2 to get the 2nd message prefetched. 
   
   To have the precise behavior of 1 single message, you need to disable pre-fetching completely, by setting `receiver_queue_size=0`. 


-- 
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