diff --git a/src/ServiceControl.Transports.SqlServer/SqlServerQuery.cs b/src/ServiceControl.Transports.SqlServer/SqlServerQuery.cs
index 38b0d67ad4..86b66146b0 100644
--- a/src/ServiceControl.Transports.SqlServer/SqlServerQuery.cs
+++ b/src/ServiceControl.Transports.SqlServer/SqlServerQuery.cs
@@ -25,7 +25,7 @@ protected override void InitializeCore(ReadOnlyDictionary<string, string> settin
         {
             logger.LogInformation("Using ConnectionString used by instance");
 
-            connectionString = transportSettings.ConnectionString;
+            connectionString = transportSettings.ConnectionString.RemoveCustomConnectionStringParts(out string _, out string _);
 
             Diagnostics.AppendLine("ConnectionString not set, defaulted to using ConnectionString used by instance");
         }