telnoratti opened a new issue, #1319:
URL: https://github.com/apache/pulsar-client-go/issues/1319
#### Expected behavior
Setting EnableZeroQueueConsumer in the ConsumerOptions along with a DLQ
policy or RetryEnable set to true, then calling Receive should return a message
if there are messages.
#### Actual behavior
It never returns and there's an error printed `ERRO[0000] unable to send
initial permits to broker consumerID=2 error="invalid number of permits
requested: 0" name=jgehd subscription=<subscription>
topic="persistent://tenant/namespace/topic"`.
#### Steps to reproduce
```go
consumer, err = client.Subscribe(pulsar.ConsumerOptions{
Topic: "persistent://tenant/namespace/topic",
SubscriptionName: "subscription",
Type: pulsar.Shared,
RetryEnable: true, // When set to false this
works as expected
EnableZeroQueueConsumer: true,
}
consumer.Receive(context.Background()) // never returns even if there are
messages
```
If I had to guess, I'd say that since this is because `multiTopicConsumer`
it's not using the zeroQueueConsumer implementation. I am running with the
patch from https://github.com/apache/pulsar-client-go/pull/1278.
#### System configuration
**Pulsar version**: 3.3.1
**Library version**: 0.14.1
--
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]
