diff --git a/packages/db/src/buffers/event-buffer-psql.ts b/packages/db/src/buffers/event-buffer-psql.ts
index 39e967e4..d1afe2ec 100644
--- a/packages/db/src/buffers/event-buffer-psql.ts
+++ b/packages/db/src/buffers/event-buffer-psql.ts
@@ -14,8 +14,8 @@ export class EventBuffer extends BaseBuffer {
   private daysToKeep = process.env.EVENT_BUFFER_DAYS_TO_KEEP
     ? Number.parseInt(process.env.EVENT_BUFFER_DAYS_TO_KEEP, 10)
     : 3;
-  private batchSize = process.env.EVENT_BUFFER_CHUNK_SIZE
-    ? Number.parseInt(process.env.EVENT_BUFFER_CHUNK_SIZE, 10)
+  private batchSize = process.env.EVENT_BUFFER_BATCH_SIZE
+    ? Number.parseInt(process.env.EVENT_BUFFER_BATCH_SIZE, 10)
     : 2000;
   private chunkSize = process.env.EVENT_BUFFER_CHUNK_SIZE
     ? Number.parseInt(process.env.EVENT_BUFFER_CHUNK_SIZE, 10)
diff --git a/packages/db/src/buffers/profile-buffer-psql.ts b/packages/db/src/buffers/profile-buffer-psql.ts
index 7233c3c7..1883015d 100644
--- a/packages/db/src/buffers/profile-buffer-psql.ts
+++ b/packages/db/src/buffers/profile-buffer-psql.ts
@@ -11,8 +11,8 @@ export class ProfileBuffer extends BaseBuffer {
   private daysToKeep = process.env.PROFILE_BUFFER_DAYS_TO_KEEP
     ? Number.parseInt(process.env.PROFILE_BUFFER_DAYS_TO_KEEP, 10)
     : 7;
-  private batchSize = process.env.PROFILE_BUFFER_CHUNK_SIZE
-    ? Number.parseInt(process.env.PROFILE_BUFFER_CHUNK_SIZE, 10)
+  private batchSize = process.env.PROFILE_BUFFER_BATCH_SIZE
+    ? Number.parseInt(process.env.PROFILE_BUFFER_BATCH_SIZE, 10)
     : 2000;
   private chunkSize = process.env.PROFILE_BUFFER_CHUNK_SIZE
     ? Number.parseInt(process.env.PROFILE_BUFFER_CHUNK_SIZE, 10)