d

Signed-off-by: myan <[email protected]>
stolostron · Aug 9, 2024 · dc7bf27 · dc7bf27
1 parent da4f825
commit dc7bf27
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 9 deletions.
diff --git a/operator/pkg/controllers/addon/addon_controller_manifests.go b/operator/pkg/controllers/addon/addon_controller_manifests.go
@@ -230,10 +230,10 @@ func (a *HohAgentAddon) GetValues(cluster *clusterv1.ManagedCluster,
 		KafkaCACert:           kafkaConnection.CACert,
 		KafkaClientCert:       kafkaConnection.ClientCert,
 		KafkaClientKey:        kafkaConnection.ClientKey,
-		KafkaClientCertSecret: commonutils.AgentCertificateSecretName(),
-		KafkaSpecTopic:        clusterTopic.SpecTopic,
-		KafkaStatusTopic:      clusterTopic.StatusTopic,
-		TransportType:         string(transport.Kafka),
+		KafkaClientCertSecret: base64.StdEncoding.EncodeToString([]byte(commonutils.AgentCertificateSecretName())),
+		KafkaSpecTopic:        base64.StdEncoding.EncodeToString([]byte(clusterTopic.SpecTopic)),
+		KafkaStatusTopic:      base64.StdEncoding.EncodeToString([]byte(clusterTopic.StatusTopic)),
+		TransportType:         base64.StdEncoding.EncodeToString([]byte(transport.Kafka)),
 		LeaseDuration:         strconv.Itoa(electionConfig.LeaseDuration),
 		RenewDeadline:         strconv.Itoa(electionConfig.RenewDeadline),
 		RetryPeriod:           strconv.Itoa(electionConfig.RetryPeriod),

diff --git a/...ers/addon/manifests/templates/agent/multicluster-global-hub-agent-kafka-certs-secret.yaml b/...ers/addon/manifests/templates/agent/multicluster-global-hub-agent-kafka-certs-secret.yaml
@@ -12,9 +12,9 @@ data:
   "ca.crt": "{{.KafkaCACert}}"
   "client.crt": "{{.KafkaClientCert}}"
   "client.key": "{{.KafkaClientKey}}"
-  # "bootstrap_server": "{{.KafkaBootstrapServer}}"
-  # "type": "{{.TransportType}}"
-  # "status_topic": "{{.KafkaStatusTopic}}"
-  # "spec_topic": "{{.KafkaSpecTopic}}"
-  # "client_secret": "{{.KafkaClientCertSecret}}"
+  "bootstrap_server": "{{.KafkaBootstrapServer}}"
+  "type": "{{.TransportType}}"
+  "status_topic": "{{.KafkaStatusTopic}}"
+  "spec_topic": "{{.KafkaSpecTopic}}"
+  "client_secret": "{{.KafkaClientCertSecret}}"
 {{- end -}}