-
Notifications
You must be signed in to change notification settings - Fork 592
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
rpk: Add Support for Topic Mounting and Unmounting #23575
rpk: Add Support for Topic Mounting and Unmounting #23575
Conversation
cf4635d
to
3bd56c3
Compare
3f33a71
to
a3b1800
Compare
6e0879a
to
5afc378
Compare
ducktape was retried in https://buildkite.com/redpanda/redpanda/builds/56392#01927db5-11d8-448d-b8f2-48b136c29ca8 |
Retry command for Build#56392please wait until all jobs are finished before running the slash command
|
The unmount process ensures data safety and cluster integrity. Every | ||
acknowledged message before the initiation of unmount is guaranteed to be | ||
persisted in Tiered Storage, subject to Redpanda's existing data safety | ||
guarantees. |
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.
@mattschumpert Do we want this in the rpk docs or would we have it elsewhere? It is important, but I wonder if rpk is the right place for this information.
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.
Removed it
|
||
Mount topic my-topic from Tiered Storage to the cluster in the my-namespace | ||
with my-new-topic as the new topic name | ||
rpk cluster storage mount my-namespace/my-topic --to my-namespace/my-new-topic |
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.
Are other namespaces supported? It appears that at least the Admin API call only supports kafka
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.
Well there's support for namespace in the spec for migration/mount and we auto-define the kafka namespace if they don't provide one
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.
This PR needs to have bazel run //:gazelle
run
640545d
to
792effe
Compare
Retry command for Build#56493please wait until all jobs are finished before running the slash command
|
non flaky failures in https://buildkite.com/redpanda/redpanda/builds/56493#01928d0c-8db0-4949-880a-aba194a4eb7f:
|
792effe
to
edbf1b9
Compare
0b3db92
to
0067cd9
Compare
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!
Adds mount/unmount support
0067cd9
to
75c20ea
Compare
Adds support for mounting and unmounting a topic to and from tiered storage with RPK. Also adds list, status and cancel commands.
Backports Required
Release Notes
Features