diff --git a/mongo_connector/doc_managers/mongo_doc_manager.py b/mongo_connector/doc_managers/mongo_doc_manager.py
index 5814a1b7..708d2c90 100644
--- a/mongo_connector/doc_managers/mongo_doc_manager.py
+++ b/mongo_connector/doc_managers/mongo_doc_manager.py
@@ -145,11 +145,6 @@ def handle_command(self, doc, namespace, timestamp):
             if a and b:
                 self.mongo.admin.command("renameCollection", a, to=b)
 
-        if doc.get("create"):
-            new_db, coll = self.command_helper.map_collection(db, doc["create"])
-            if new_db:
-                self.mongo[new_db].create_collection(coll)
-
         if doc.get("drop"):
             new_db, coll = self.command_helper.map_collection(db, doc["drop"])
             if new_db: