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, " ")
}