Comcast / Comcast/pulsar-client-go
ManagedConsumer: queue size 1 behaves incorrectly
Open
bug
- Dominant language
- Go
- Stars
- 79
- Forks
- 38
- PR merge metrics
- No merged PRs in 30d
Description
#### Expected behavior
When using a managed consumer with QueueSize == 1, eg
```
c := pulsar.ManagedConsumerConfig{
QueueSize: 1,
}
```
Then it's expected that `c.ReceiveAsync` receive messages.
#### Actual behavior
The managed consumer incorrectly sets the highwater to 0, which incorrectly performs flow control.
#### System configuration
`v0.0.1`
Contributor guide
Assessment
This issue has not been assessed yet.