-
Notifications
You must be signed in to change notification settings - Fork 14.2k
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
MINOR: Move Throttler to storage module #16023
Conversation
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
@mimaison nice patch! One small comment is left. Also, could you please cleanup the spotbugs file?
kafka/gradle/spotbugs-exclude.xml
Line 495 in affe8da
<Package name="kafka.utils"/> |
time = time) | ||
private[log] val throttler = new Throttler(config.maxIoBytesPerSecond, | ||
300, | ||
true, |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
It seems throttleDown
is always true in production. Maybe we can remove it?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Right this can be removed. Done.
I also removed the spotbugs exclusion.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
LGTM
None of the test failures seem related, merging to trunk. |
Reviewers: Chia-Ping Tsai <[email protected]>
Reviewers: Chia-Ping Tsai <[email protected]>
Reviewers: Chia-Ping Tsai <[email protected]>
Reviewers: Chia-Ping Tsai <[email protected]>
Throttler is one of the dependencies required in order to move LogCleaner out of core.
Committer Checklist (excluded from commit message)