in pkg/controller/topictransfer/topictransfer_controller.go [475:484]
func buildCheckConsumeProgressCommand(consumerGroup string, nameServer string) string {
cmdOpts := []string{
"consumerprogress",
"-g",
consumerGroup,
"-n",
nameServer,
}
return strings.Join(cmdOpts, " ")
}