reassign

var Cmd = &cobra.Command{
	Use:   "reassign",
	Short: "Execute a single partition reassignment",
	RunE: func(cmd *cobra.Command, args []string) error {
		client := &kafka.Client{Addr: kafka.TCP(vars.BootstrapServer)}

		brokerIDs, err := getBrokerIDs(replicas)
		if err != nil {
			return fmt.Errorf("problem parsing replica set: %w", err)
		}

		err = Partition(client, topic, partition, brokerIDs)
		if err != nil {
			return err
		}

		fmt.Println("Reassignment executed.")
		return nil
	},
}