func buildAddRetryTopicToClusterCommand()

in pkg/controller/topictransfer/topictransfer_controller.go [403:420]


func buildAddRetryTopicToClusterCommand(consumerGroup string, cluster string, nameServer string) string {
	cmdOpts := []string{
		"updatetopic",
		"-t",
		"%RETRY%" + consumerGroup,
		"-c",
		cluster,
		"-r",
		"1",
		"-w",
		"1",
		"-p",
		"6",
		"-n",
		nameServer,
	}
	return strings.Join(cmdOpts, " ")
}