[CLOUDTRUST-3991] Add tls to Kafka config (#121)

cloudtrust · May 30, 2023 · 45efd7b · 45efd7b
1 parent dae7be6
commit 45efd7b
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/events/kafkaproducer.go b/events/kafkaproducer.go
@@ -57,6 +57,8 @@ 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
+
 	producer, err := sarama.NewSyncProducer(c.Brokers, config)
 	if err != nil {
 		logger.Error(ctx, "msg", "Failed to start Kafka producer", "error", err)