stage

var Cmd = &cobra.Command{
	Use:   "stage",
	Short: "Execute a series of partition reassignments",
	Long:  long,
	RunE: func(cmd *cobra.Command, args []string) error {
		rs, err := readReassignments(reassignmentsFilepath)
		if err != nil {
			return fmt.Errorf("problem reading reassignments json file: %w", err)
		}

		if rs.Version != 1 {
			return fmt.Errorf("unsupported version '%d'", rs.Version)
		}

		client := &kafka.Client{Addr: kafka.TCP(vars.BootstrapServer)}

		err = ReconcileUntilDone(client, rs, maxMovesPerBroker, dryRun)
		if err != nil {
			return err
		}

		fmt.Println("Reassignments complete.")
		return nil
	},
}