gkhnoztrk
gkhnoztrk
 The expected behavior with EnableZeroQueueConsumer set to true should be as follows: 50 tasks were placed in the queue. Each consumer was limited to processing 5 tasks concurrently. 4...
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() } ```...