func buildAddConsumerGroupToClusterCommand()

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