Merge pull request #421 from target/SSLFix

Bugfix: Add fix for SSL CA Bundle Verification Issue
target · Jan 4, 2024 · 3a32308 · 3a32308
2 parents 37ef3c4 + 300c4e6
commit 3a32308
Showing 1 changed file with 6 additions and 5 deletions.
diff --git a/src/go/cmd/strelka-frontend/main.go b/src/go/cmd/strelka-frontend/main.go
@@ -291,11 +291,12 @@ func main() {
 		if !*locallog && *kafkalog {
 			log.Printf("Creating new Kafka producer.")
 			p, err := kafka.NewProducer(&kafka.ConfigMap{
-				"bootstrap.servers":        conf.Broker.Bootstrap,
-				"security.protocol":        conf.Broker.Protocol,
-				"ssl.certificate.location": conf.Broker.Certlocation,
-				"ssl.key.location":         conf.Broker.Keylocation,
-				"ssl.ca.location":          conf.Broker.Calocation,
+				"bootstrap.servers":                     conf.Broker.Bootstrap,
+				"security.protocol":                     conf.Broker.Protocol,
+				"ssl.certificate.location":              conf.Broker.Certlocation,
+				"ssl.key.location":                      conf.Broker.Keylocation,
+				"ssl.ca.location":                       conf.Broker.Calocation,
+				"ssl.endpoint.identification.algorithm": "none",
 			})
 			if err != nil {
 				log.Fatalf("FAILED TO CREATE KAFKA PRODUCER: ERROR %v", err)