func undoDeleteConsumeGroup()

in pkg/controller/topictransfer/topictransfer_controller.go [313:324]

• 12 lines of code
• 4 McCabe index (conditional complexity)

func undoDeleteConsumeGroup(consumerGroups []string, cluster string, nameServer string) {
	for _, consumerGroup := range consumerGroups {
		addConsumerGroupToTargetClusterCommand := buildAddConsumerGroupToClusterCommand(consumerGroup, cluster, nameServer)
		log.Info("undoDeleteConsumeGroup: " + addConsumerGroupToTargetClusterCommand)
		cmd := exec.Command(cons.BasicCommand, cons.AdminToolDir, addConsumerGroupToTargetClusterCommand)
		output, err := cmd.Output()
		if err != nil || !isUpdateConsumerGroupSuccess(string(output)) {
			log.Error(err, "Failed to undo delete consume group with output: "+string(output))
		}
		log.Info("Successfully undo delete consume group with output: " + string(output))
	}
}