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-13127; Fix stray topic partition deletion for kraft #11118
Conversation
core/src/test/scala/unit/kafka/server/AbstractApiVersionsRequestTest.scala
Show resolved
Hide resolved
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. Great find @hachikuji !
left a few comments
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 @hachikuji. The additional logging is much appreciated here :)
One minor comment, otherwise LGTM
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.
This patch fixes BrokerMetadataPublisher.findGhostReplicas (renamed to findStrayPartitions) so that it returns the stray partitions. Previously it was returning the non-stray partitions. This caused all of these partitions to get deleted on startup by mistake. Reviewers: Colin P. McCabe <cmccabe@apache.org>, José Armando García Sancio <jsancio@gmail.com>
This patch fixes BrokerMetadataPublisher.findGhostReplicas (renamed to findStrayPartitions) so that it returns the stray partitions. Previously it was returning the non-stray partitions. This caused all of these partitions to get deleted on startup by mistake. Reviewers: Colin P. McCabe <cmccabe@apache.org>, José Armando García Sancio <jsancio@gmail.com>
This patch fixes
BrokerMetadataPublisher.findGhostReplicas
(renamed tofindStrayPartitions
) so that it returns the stray partitions. Previously it was returning the non-stray partitions.Committer Checklist (excluded from commit message)