diff --git a/src/main/java/io/autoinvestor/infrastructure/UserCreatedEventDocument.java b/src/main/java/io/autoinvestor/infrastructure/UserCreatedEventDocument.java
index e53f945..c2b97fc 100644
--- a/src/main/java/io/autoinvestor/infrastructure/UserCreatedEventDocument.java
+++ b/src/main/java/io/autoinvestor/infrastructure/UserCreatedEventDocument.java
@@ -6,7 +6,7 @@
 
 import java.time.Instant;
 
-@Document(collection = "userCreated")
+@Document(collection = "events")
 public record UserCreatedEventDocument(
         @Id String id,
         String aggregateId,
diff --git a/src/main/java/io/autoinvestor/infrastructure/UserReadModelDocument.java b/src/main/java/io/autoinvestor/infrastructure/UserReadModelDocument.java
index 9cb10dc..50efef7 100644
--- a/src/main/java/io/autoinvestor/infrastructure/UserReadModelDocument.java
+++ b/src/main/java/io/autoinvestor/infrastructure/UserReadModelDocument.java
@@ -3,7 +3,7 @@
 import org.springframework.data.annotation.Id;
 import org.springframework.data.mongodb.core.mapping.Document;
 
-@Document(collection = "usersReadModel")
+@Document(collection = "users")
 public record UserReadModelDocument(
         @Id String userId,
         String email,