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]