check for topic creation

metadata-ingestion/tests/integration/kafka-connect/test_kafka_connect.py

@@ -313,7 +313,20 @@ def test_kafka_connect_mongosourceconnect_ingest(
         )
 
         # Give time for connectors to process the table data
-        time.sleep(60)
+        time.sleep(30)
+
+        i = 0
+
+        while i < 20:
+            r = requests.get(
+                "http://localhost:58083/connectors/source_mongodb_connector/topics"
+            )
+            data = r.json()
+            if "mongodb.test_db.purchases" in data:
+                break
+
+            i += 1
+            time.sleep(5)
 
         # Run the metadata ingestion pipeline.
         config_file = (test_resources_dir / "kafka_connect_to_file.yml").resolve()