diff --git a/src/main/java/com/uid2/optout/delta/DeltaProductionOrchestrator.java b/src/main/java/com/uid2/optout/delta/DeltaProductionOrchestrator.java
index a4ffc19..71c2860 100644
--- a/src/main/java/com/uid2/optout/delta/DeltaProductionOrchestrator.java
+++ b/src/main/java/com/uid2/optout/delta/DeltaProductionOrchestrator.java
@@ -265,7 +265,7 @@ private void writeDroppedRequestEntry(JsonArray droppedRequestArray, SqsParsedMe
      * Generates a unique filename for dropped requests.
      */
     private String generateDroppedRequestFileName() {
-        return String.format("%s%03d_%s_%08x.json", 
+        return String.format("dropped/%s%03d_%s_%08x.json", 
                 "optout-dropped-", 
                 replicaId, 
                 Instant.now().truncatedTo(ChronoUnit.SECONDS).toString().replace(':', '.'), 
diff --git a/src/main/java/com/uid2/optout/vertx/OptOutSqsLogProducer.java b/src/main/java/com/uid2/optout/vertx/OptOutSqsLogProducer.java
index 26ad9d0..c33b11d 100644
--- a/src/main/java/com/uid2/optout/vertx/OptOutSqsLogProducer.java
+++ b/src/main/java/com/uid2/optout/vertx/OptOutSqsLogProducer.java
@@ -142,7 +142,7 @@ public OptOutSqsLogProducer(JsonObject jsonConfig, ICloudStorage cloudStorage, I
         SqsWindowReader windowReader = new SqsWindowReader(
             this.sqsClient, queueUrl, maxMessagesPerPoll, 
             visibilityTimeout, deltaWindowSeconds, maxMessagesPerFile,
-            malformedRequestUploadService, "malformed", replicaId
+            malformedRequestUploadService, "malformed/", replicaId
         );
 
         this.orchestrator = new DeltaProductionOrchestrator(