search

ayeo-flex-org / pulsar-flex

Pulsar Flex is a modern Apache Pulsar client for Node.js, developed to be independent of C++.
MIT License
45 stars 9 forks source link

Consumer only reads the number of messages in receiveQueueSize #71

Closed sOfekS closed 3 years ago

sOfekS commented 3 years ago

Describe the bug Consumer only gets the number of messages in receiveQueueSize and then stops reading.

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 the consumer has consumed receiveQueueSize messages, it stops. Expected behavior I expect it to read that number of messages as a sort of batch (only that amount can fit in the queue at once) but to still keep reading after reaching that amount.

Observed behavior After the consumer has consumed receiveQueueSize messages, it just stops consuming messages.

Environment:

Additional context

sOfekS commented 3 years ago

Closing. The issue was Node version under v14, now working with v16.13.0 and it works.