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 Memory Leak, Hanging promises. #79

Closed ronfarkash closed 2 years ago

ronfarkash commented 2 years ago

Describe the bug When consuming messages, a memory leak is created due to unresolved promises. After leaving the consumer on for a while, a heap snapshot will show an increasing number of promise references.

Reproduce

  1. Run a Consumer that continuously reads messages.
  2. Watch the process memory go up as time passes.

Expected behavior The process memory to stay stable.

Observed behavior Explained above.

Environment: