func undoDeleteTopic()

in pkg/controller/topictransfer/topictransfer_controller.go [302:311]


func undoDeleteTopic(topic string, cluster string, nameServer string) {
	addTopicToClusterCommand := buildAddTopicToClusterCommand(topic, cluster, nameServer)
	log.Info("undoDeleteTopic: " + 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 delete topic with output: "+string(output))
	}
	log.Info("Successfully undo delete topic with output: " + string(output))
}