pulsar-client-go icon indicating copy to clipboard operation
pulsar-client-go copied to clipboard

ManagedConsumer: queue size 1 behaves incorrectly

Open awilliams opened this issue 6 years ago • 0 comments

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

awilliams avatar Sep 20 '18 19:09 awilliams