diff --git a/kotlin-fit-performer/src/main/kotlin/com/couchbase/client/performer/kotlin/KotlinPerformer.kt b/kotlin-fit-performer/src/main/kotlin/com/couchbase/client/performer/kotlin/KotlinPerformer.kt
index 3a0cdda41..89fc31dda 100644
--- a/kotlin-fit-performer/src/main/kotlin/com/couchbase/client/performer/kotlin/KotlinPerformer.kt
+++ b/kotlin-fit-performer/src/main/kotlin/com/couchbase/client/performer/kotlin/KotlinPerformer.kt
@@ -58,6 +58,7 @@ class KotlinPerformer : CorePerformer() {
             .addSdkImplementationCaps(Caps.SDK_SEARCH_INDEX_MANAGEMENT)
             .addSdkImplementationCaps(Caps.SDK_SCOPE_SEARCH_INDEX_MANAGEMENT)
             .addPerformerCaps(PerformerCaps.CLUSTER_CONFIG_CERT)
+            .addPerformerCaps(PerformerCaps.CLUSTER_CONFIG_INSECURE)
     }
 
     override fun clusterConnectionCreate(
diff --git a/kotlin-fit-performer/src/main/kotlin/com/couchbase/client/performer/kotlin/util/ClusterConnection.kt b/kotlin-fit-performer/src/main/kotlin/com/couchbase/client/performer/kotlin/util/ClusterConnection.kt
index ec1d60a8d..56010f477 100644
--- a/kotlin-fit-performer/src/main/kotlin/com/couchbase/client/performer/kotlin/util/ClusterConnection.kt
+++ b/kotlin-fit-performer/src/main/kotlin/com/couchbase/client/performer/kotlin/util/ClusterConnection.kt
@@ -16,6 +16,7 @@
 
 package com.couchbase.client.performer.kotlin.util
 
+import com.couchbase.client.core.deps.io.netty.handler.ssl.util.InsecureTrustManagerFactory
 import com.couchbase.client.core.env.SecurityConfig
 import com.couchbase.client.kotlin.Cluster
 import com.couchbase.client.kotlin.Collection
@@ -76,6 +77,7 @@ class ClusterConnection(req: ClusterConnectionCreateRequest) {
 
 private val ClusterConfig.trustSource: TrustSource
     get() = when {
+        hasInsecure() && insecure -> TrustSource.factory(InsecureTrustManagerFactory.INSTANCE)
         hasCertPath() -> TrustSource.certificate(Path(certPath))
         hasCert() -> TrustSource.certificates(SecurityConfig.decodeCertificates(listOf(cert)))
         else -> TrustSource.certificates(SecurityConfig.defaultCaCertificates())