diff --git a/producer/producer_config.go b/producer/producer_config.go index 5b09d61..e4daae6 100644 --- a/producer/producer_config.go +++ b/producer/producer_config.go @@ -20,7 +20,7 @@ func GetSyncProducerConfig(kafkaConfiguration config.KafkaConfigurations) *saram config := sarama.NewConfig() // security configs - // config.Net.TLS.Enable = true + config.Net.TLS.Enable = true // config.Net.SASL.Enable = true // config.Net.SASL.Handshake = true // config.Net.SASL.Mechanism = sarama.SASLTypePlaintext @@ -45,7 +45,7 @@ func GetAsyncProducerConfig(kafkaConfiguration config.KafkaConfigurations) *sara config := sarama.NewConfig() // security configs - // config.Net.TLS.Enable = true + config.Net.TLS.Enable = true // config.Net.SASL.Enable = true // config.Net.SASL.Handshake = true // config.Net.SASL.Mechanism = sarama.SASLTypePlaintext