diff --git a/sources/dynamodb/offsets/offsets.go b/sources/dynamodb/offsets/offsets.go
index 7aef91c1..dcf34079 100644
--- a/sources/dynamodb/offsets/offsets.go
+++ b/sources/dynamodb/offsets/offsets.go
@@ -8,7 +8,7 @@ import (
 )
 
 // ShardExpirationAndBuffer - Buffer for when a shard is closed as the records have a TTL of 24h. However, garbage collection is async.
-const ShardExpirationAndBuffer = 2 * 24 * time.Hour
+const ShardExpirationAndBuffer = 3 * 24 * time.Hour
 
 type OffsetStorage struct {
 	ttlMap *ttlmap.TTLMap