New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

Consumer only reads the number of messages in receiveQueueSize #71

Closed

sOfekS opened this issue Nov 11, 2021 · 1 comment · Fixed by #74

Assignees

Labels

bug

Collaborator

sOfekS commented Nov 11, 2021

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

Reproduce
Please provide reproduce, For example:

Run a producer that continuously produces messages to a topic
Run a consumer that subscribes to that topic and logs each topic offset
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:

OS: CentOS 7.8
PulsarFlex version 1.0.1-beta.4
Pulsar version 2.8.1
NodeJS version 13.1.0

Additional context

galrose added the bug label

galrose self-assigned this

galrose mentioned this issue

Task/fix reflow #74

Merged

sOfekS closed this as completed

Collaborator Author

sOfekS commented Nov 16, 2021

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

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment