diff --git a/core/trino-main/src/main/java/io/trino/server/testing/TestingTrinoServer.java b/core/trino-main/src/main/java/io/trino/server/testing/TestingTrinoServer.java
index 06d489907be7..b746979f1f1d 100644
--- a/core/trino-main/src/main/java/io/trino/server/testing/TestingTrinoServer.java
+++ b/core/trino-main/src/main/java/io/trino/server/testing/TestingTrinoServer.java
@@ -439,6 +439,10 @@ public CatalogHandle createCatalog(String catalogName, String connectorName, Map
     {
         CatalogHandle catalogHandle = connectorManager.createCatalog(catalogName, connectorName, properties);
         updateConnectorIdAnnouncement(announcer, catalogHandle, nodeManager);
+
+        EventListenerManager eventListenerManager = injector.getInstance(EventListenerManager.class);
+        connectorManager.getConnectorServices(catalogHandle).getEventListeners().forEach(eventListenerManager::addEventListener);
+
         return catalogHandle;
     }