-
Notifications
You must be signed in to change notification settings - Fork 13.6k
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
KAFKA-14550: Move SnapshotFile and CorruptSnapshotException to storage module #13039
KAFKA-14550: Move SnapshotFile and CorruptSnapshotException to storage module #13039
Conversation
67f14e9
to
314cfec
Compare
@satishd Can you please fix the conflicts? |
6006703
to
ffe2c0a
Compare
ffe2c0a
to
187d7f7
Compare
@ijuma These changes are updated with the latest trunk and resolved the conflicts. |
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.
Thanks for the PR. Looks good overall, a few minor comments below.
storage/src/main/java/org/apache/kafka/server/log/internals/SnapshotFile.java
Outdated
Show resolved
Hide resolved
storage/src/main/java/org/apache/kafka/server/log/internals/SnapshotFile.java
Show resolved
Hide resolved
@satishd did you see my review above? |
Addressed review comments.
…ced offsetFromFileName in UnifiedLog/LocalLog.
@ijuma Sorry, Brave browser(+plugins) had some issues in refreshing the github PR page and missed your update. |
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, thanks.
The build for all 3 JDK versions passed. |
…e module (apache#13039) For broader context on this change, see: * KAFKA-14470: Move log layer to storage module Reviewers: Ismael Juma <ismael@juma.me.uk>
KAFKA-14550 Move SnapshotFile and CorruptSnapshotException to storage module.
For broader context on this change, you may want to look at KAFKA-14470: Move log layer to storage module
Committer Checklist (excluded from commit message)