diff --git a/base/mqueue/mqueue_impl_gokafka.go b/base/mqueue/mqueue_impl_gokafka.go
index 30f8d001f..0f166225c 100644
--- a/base/mqueue/mqueue_impl_gokafka.go
+++ b/base/mqueue/mqueue_impl_gokafka.go
@@ -121,10 +121,8 @@ func tryCreateSecuredDialerFromEnv() *kafka.Dialer {
 	}
 
 	kafkaSslSkipVerify := utils.CoreCfg.KafkaSslSkipVerify
-	var tlsConfig *tls.Config
-	if kafkaSslSkipVerify {
-		tlsConfig = &tls.Config{InsecureSkipVerify: true} // nolint:gosec
-	} else {
+	tlsConfig := &tls.Config{InsecureSkipVerify: kafkaSslSkipVerify} // nolint:gosec
+	if !kafkaSslSkipVerify {
 		tlsConfig = caCertTLSConfig()
 	}