lhotari commented on PR #25061: URL: https://github.com/apache/pulsar/pull/25061#issuecomment-3638699032
> Refactored consumer dispatch to consume rate-limiting tokens before sending messages, ensuring that the total messages and bytes do not exceed available tokens. In the AsyncTokenBucket implementation, it's not a problem if the tokens are exceeded in a point in time since the algorithm will smooth out the average. One possible improvement to the existing solution could be to acquire tokens based on some estimate before reading the entries and adjust the tokens later, after sending (like it's currently performed). -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
