-
Notifications
You must be signed in to change notification settings - Fork 628
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.
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
maxTickMessages is not working #1456
Comments
same issue here, getting more than maxTickMessages(100) from consumer
|
@praveenydv @mmsqe I think this is the expected behaviour in latest versions because For example, if the consumer fetches 1000 messages and if the If all 1000 messages were emitted sequentially (without batching), and if your message handler is completely synchronous and blocking, your app won't be able to perform any other task until all 1000 messages were processed. But with However, in earlier kafka-node versions (don't remember which exactly), So, if you are using a recent version of kafka-node (I guess maybe 5.x.x onwards), you will need to only use Maybe a contributor of kafka-node might be able to provide more info (and/or if I'm incorrect) |
When I am trying to fix my message per batch using maxTickMessages. But It is not affecting anything means it is not controlling number of message per batch.
Even if I am putting maxTickMessages=0 then I am getting messages.
I am getting messages on the basis of fetchMaxBytes no matter what I put value of maxTickMessages.
In the above code I am trying to fetch fix number( equal to maxTickMessages ) of messages in every 5 seconds.
But I am getting messages on the basis of fetchMaxBytes limit.
The text was updated successfully, but these errors were encountered: