-
Notifications
You must be signed in to change notification settings - Fork 298
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-17146 Include note to remove migration znode #620
base: asf-site
Are you sure you want to change the base?
Conversation
of the brokers can become the new old-style controller. Additionally, run | ||
<code>get /migration</code> followed by <code>rmr /migration</code> to clear the | ||
migration state from ZooKeeper. This will allow you to re-attempt the migration | ||
in the future. The data read from "/migration" can be useful for debugging. |
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.
We also need to update it in L4147 (Migrating brokers to KRaft
row)
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.
oh, I don't notice this comment. apache/kafka#16770 is merged. I will sync the changes back to kafka repo if it needs
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.
I have commented the corresponding JIRA to understand in which state the user rollbacks the cluster to restart the migration because I tried this scenario more times without deleting the /migration znode and it worked fine.
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 @showuon, added the second mention. I wonder why we have this duplication? 🤔
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.
I wonder why we have this duplication?
it seems we list all directions for reverting for each migration phase. That is a bit verbose, but they are useful. However, it is weird to use "table format" to display so much texts. Maybe we should to a bit refactor for it. Also, the same direction can have its hyperlink to be shared in different migration phase.
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.
I file jira for it (https://issues.apache.org/jira/browse/KAFKA-17271)
@mumrah -- can this PR be merged? |
It's still not clear to me why this removal is needed. I ran migration then rollback then migration and so on several times without the need for deleting such znode. |
When reverting the ZK migration, we must also remove the
/migration
ZNode in order to allow the migration to be re-attempted in the future.