func CreateOrderlyConsumerGroup()

in golang/utils/MQAdminUtils.go [122:141]

• 19 lines of code
• 5 McCabe index (conditional complexity)

func CreateOrderlyConsumerGroup(consumerGroup string, brokerAddr string, clusterName string, nameserver string) {
	// use absolute path
	command := "sh " + root + "/rocketmq-admintools/bin/mqadmin updateSubGroup -g " + consumerGroup
	if nameserver != "" {
		command += " -n " + nameserver
	}
	if brokerAddr != "" {
		command += " -b " + brokerAddr
	}
	if clusterName != "" {
		command += " -c " + clusterName
	}
	command += " -s true -o true -m false -d false "
	fmt.Println(command)
	out, err := exec.Command("/bin/bash", "-c", command).Output()
	if err != nil {
		log.Fatal(err)
	}
	fmt.Println(string(out))
}