fix(kafka): kafka manager不展示消费组信息 TencentBlueKing#7975

zfrendo · Nov 15, 2024 · 69d376b · 69d376b
1 parent 12743dd
commit 69d376b
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/dbm-services/bigdata/db-tools/dbactuator/pkg/components/kafka/install_kafka.go b/dbm-services/bigdata/db-tools/dbactuator/pkg/components/kafka/install_kafka.go
@@ -983,8 +983,9 @@ func configCluster(cmak CmakConfig, noSecurity int) (err error) {
 
 	zookeeperIPList := strings.Split(cmak.ZookeeperIP, ",")
 	zkHosts := fmt.Sprintf("%s:2181,%s:2181,%s:2181/", zookeeperIPList[0], zookeeperIPList[1], zookeeperIPList[2])
-	jaasConfig := fmt.Sprintf("%s required username=%s  password=%s ;",
-		"org.apache.kafka.common.security.scram.ScramLoginModule", cmak.Username, cmak.Password)
+	jaasConfig := fmt.Sprintf(
+		`org.apache.kafka.common.security.scram.ScramLoginModule required username="%s" password="%s" ;`, cmak.Username,
+		cmak.Password)
 	postData := url.Values{}
 	postData.Add("name", cmak.ClusterName)
 	postData.Add("zkHosts", zkHosts)