in pkg/controller/topictransfer/topictransfer_controller.go [503:518]
func buildAddConsumerGroupToClusterCommand(consumerGroup string, cluster string, nameServer string) string {
cmdOpts := []string{
"updatesubgroup",
"-g",
consumerGroup,
"-c",
cluster,
"-m",
"true",
"-d",
"true",
"-n",
nameServer,
}
return strings.Join(cmdOpts, " ")
}