Added flag for insecureSkipVerfiy (#1829)

charts/fission-all/templates/deployment.yaml

@@ -678,6 +678,8 @@ spec:
           value: "true"
         - name: MESSAGE_QUEUE_SECRETS
           value: /etc/fission/secrets
+        - name: INSECURE_SKIP_VERIFY
+          value: "{{ .Values.kafka.authentication.tls.insecureSkipVerify }}"
         volumeMounts:
         - name: kafka-secrets
           mountPath: /etc/fission/secrets

charts/fission-all/values.yaml

@@ -184,6 +184,8 @@ kafka:
   authentication:
     tls:
       enabled: false
+      # InsecureSkipVerify controls whether a client verifies the server's certificate chain and host name.
+      insecureSkipVerify: false # Warning: Setting this to true, makes TLS susceptible to man-in-the-middle attacks
       caCert: "" # path to certificate containing public key of CA authority
       userCert: "" # path to certificate containing public key of the user signed by CA authority
       userKey: "" # path to private key of the user

pkg/mqtrigger/messageQueue/kafka/kafka.go

@@ -201,8 +201,12 @@ func (kafka Kafka) getTLSConfig() (*tls.Config, error) {
 
 	tlsConfig.Certificates = []tls.Certificate{cert}
 
+	skipVerify, err := strconv.ParseBool(os.Getenv("INSECURE_SKIP_VERIFY"))
 	if err != nil {
-		return nil, err
+		kafka.logger.Error("failed to parse value of env variable INSECURE_SKIP_VERIFY taking default value false, expected boolean value: true/false",
+			zap.String("received", os.Getenv("INSECURE_SKIP_VERIFY")))
+	} else {
+		tlsConfig.InsecureSkipVerify = skipVerify
 	}
 
 	caCertPool := x509.NewCertPool()