From 69d376bc5027495d2e5d4c33d9e55334668210f6 Mon Sep 17 00:00:00 2001 From: zvictorino Date: Fri, 15 Nov 2024 14:59:10 +0800 Subject: [PATCH] =?UTF-8?q?fix(kafka):=20kafka=20manager=E4=B8=8D=E5=B1=95?= =?UTF-8?q?=E7=A4=BA=E6=B6=88=E8=B4=B9=E7=BB=84=E4=BF=A1=E6=81=AF=20#7975?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../dbactuator/pkg/components/kafka/install_kafka.go | 5 +++-- 1 file changed, 3 insertions(+), 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 index b361573be0..e56cbf5090 100644 --- 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)