fix: changed asignment for k.NET

Signed-off-by: Kristoffer Olafsen <[email protected]>
argoproj-labs · Jun 28, 2022 · 0802888 · 0802888
1 parent c44b58b
commit 0802888
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/runner/sidecar/kafka.go b/runner/sidecar/kafka.go
@@ -23,10 +23,10 @@ func kafkaFromSecret(k *dfv1.Kafka, secret *corev1.Secret) error {
 	k.NET = &dfv1.KafkaNET{}
 
 	if tls != nil {
-		k.NET = &dfv1.KafkaNET{TLS: tls}
+		k.NET.TLS = tls
 	}
 	if sasl != nil {
-		k.NET = &dfv1.KafkaNET{SASL: sasl}
+		k.NET.SASL = sasl
 	}
 	return nil
 }