consumers stop receiving new data from pulsar

#### Expected behavior

the consumer should consume and receive all data.

#### Actual behavior

the consumer stops receiving new data from pulsar after have started. and
"availablePermits" : -16,

#### Steps to reproduce

Start a consumer (go client v0.8.1), the consumer will receive some data after it has started immediately, and then stops receiving. This phenomenon can recur stably.

#### System configuration
**Pulsar version**: 2.10.1
**KoP version**: 2.10.1.6

****

The report names no source file or test entry point. Start by reproducing the issue with Go client v0.8.1 against Pulsar 2.10.1 and KoP 2.10.1.6, then trace the consumer behavior when availablePermits reaches -16. Done means the consumer continues receiving all data after startup.

Written by the indexing model from the issue text.