diff --git a/src/dynamo-streams.ts b/src/dynamo-streams.ts
index 9187592..58a9580 100644
--- a/src/dynamo-streams.ts
+++ b/src/dynamo-streams.ts
@@ -249,7 +249,7 @@ export class DynamoStreamHandler<Entity, Context> {
           concurrency: this.config.concurrency ?? 5,
         },
         async (record) => {
-          const recordLogger = this.config.logger.child({
+          const recordLogger = context.logger.child({
             record: this.obfuscateRecord(record),
           });
           if (!record.dynamodb) {