From 203e7a6d8dd48916a07d228e21a70e591d709f19 Mon Sep 17 00:00:00 2001
From: Bastien Beuchat <bastien.beuchat@elca.ch>
Date: Wed, 31 May 2023 10:59:29 +0200
Subject: [PATCH] [CLOUDTRUST-3991] Parametrize TLS for kafka (#122)

---
 events/kafkaproducer.go | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/events/kafkaproducer.go b/events/kafkaproducer.go
index 98eccbe..6304744 100644
--- a/events/kafkaproducer.go
+++ b/events/kafkaproducer.go
@@ -17,6 +17,7 @@ type KafkaProducerConfig struct {
 	ClientSecret string
 	TokenURL     string
 	Noop         bool
+	TLSEnabled   bool
 }
 
 // GetKafkaProducerConfig gets a KafkaProducerConfig
@@ -31,6 +32,7 @@ func GetKafkaProducerConfig(c cs.Configuration, prefix string) KafkaProducerConf
 		cfg.ClientID = c.GetString(prefix + "-client-id")
 		cfg.ClientSecret = c.GetString(prefix + "-client-secret")
 		cfg.TokenURL = c.GetString(prefix + "-token-url")
+		cfg.TLSEnabled = c.GetBool(prefix + "-tls-enabled")
 	}
 
 	return cfg
@@ -57,7 +59,7 @@ func NewEventKafkaProducer(ctx context.Context, c KafkaProducerConfig, logger lo
 	config.Net.SASL.Mechanism = sarama.SASLTypeOAuth
 	config.Net.SASL.TokenProvider = NewTokenProvider(c.ClientID, c.ClientSecret, c.TokenURL)
 
-	config.Net.TLS.Enable = true
+	config.Net.TLS.Enable = c.TLSEnabled
 
 	producer, err := sarama.NewSyncProducer(c.Brokers, config)
 	if err != nil {