Comcast / Comcast/pulsar-client-go

ManagedConsumer: queue size 1 behaves incorrectly

Open
#12 0 comments 0 reactions 1 assignee Claimed by @awilliams View on GitHub
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

Open the contributing guide

Assessment

This issue has not been assessed yet.

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.