func undoStopWrite()

in pkg/controller/topictransfer/topictransfer_controller.go [291:300]

• 10 lines of code
• 3 McCabe index (conditional complexity)

func undoStopWrite(topic string, cluster string, nameServer string) {
	addTopicToClusterCommand := buildUndoStopWriteCommand(topic, cluster, nameServer)
	log.Info("undoStopWrite: " + addTopicToClusterCommand)
	cmd := exec.Command(cons.BasicCommand, cons.AdminToolDir, addTopicToClusterCommand)
	output, err := cmd.Output()
	if err != nil || !isUpdateTopicCommandSuccess(string(output)) {
		log.Error(err, "Failed to undo stop write topic with output: "+string(output))
	}
	log.Info("Successfully undo stop write topic with output: " + string(output))
}