feat: add TLS config for kafka producer.

2 years ago · 78d2e8f093
parent 500edc4568
commit 78d2e8f093
1 changed files with 1 additions and 0 deletions
--- a/pkg/common/kafka/producer.go
+++ b/pkg/common/kafka/producer.go
@ -60,6 +60,7 @@ func NewKafkaProducer(addr []string, topic string) *Producer {
 	}
 	p.addr = addr
 	p.topic = topic
+	SetupTLSConfig(p.config)
 	var producer sarama.SyncProducer
 	var err error
 	for i := 0; i <= maxRetry; i++ {