gkhnoztrk commented on issue #1276: URL: https://github.com/apache/pulsar-client-go/issues/1276#issuecomment-2322036161
I've found a temporary solution to my issue by modifying the following line: https://github.com/apache/pulsar-client-go/blob/953d9eab07948d94234c6a2e6b04f1ffeb8ff833/pulsar/consumer_partition.go#L1497 The modified code now looks like this: ``` if pc.options.receiverQueueSize > 0 { pc.availablePermits.inc() } ``` This change appears to address the problem I was experiencing. However, I want to emphasize that this is a temporary fix, and I'm not certain about its broader implications or whether it's the most appropriate long-term solution. I would greatly appreciate if the maintainers or someone with deeper knowledge of the codebase could review this modification and provide feedback on: Whether this approach aligns with the intended behavior of EnableZeroQueueConsumer. Potential side effects or issues this change might introduce in other scenarios. If there's a more robust or recommended way to achieve the desired behavior.  -- 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: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
