Warnings about messages going to pending queue when there is nothing wrong with the connection.

[galrose]

Describe the bug
There is a warning that messages are going to the pending queue although they should not.
Reproduce
Please provide reproduce, For example:

1. Run a producer that continuously produces messages to a topic
2. Run a consumer that subscribes to that topic and logs each topic offset
3. After a while you will start seeing warning that the messages are entering the pending queue
   Expected behavior
   When there is nothing wrong with the connection the messages should not enter the pending queue

Observed behavior

Environment:

• OS: The docker compose
• PulsarFlex version [1.12.0]
• Pulsar version [2.8.1]
• NodeJS version [14.18.1]