diff --git a/clients/s3/s3.go b/clients/s3/s3.go
index dd9f32423..6b828b24d 100644
--- a/clients/s3/s3.go
+++ b/clients/s3/s3.go
@@ -49,8 +49,7 @@ func (s *Store) IdentifierFor(topicConfig kafkalib.TopicConfig, table string) sq
 func (s *Store) ObjectPrefix(tableData *optimization.TableData) string {
 	tableID := s.IdentifierFor(tableData.TopicConfig(), tableData.Name())
 	fqTableName := tableID.FullyQualifiedName()
-	yyyyMMDDFormat := tableData.LatestCDCTs.Format(ext.PostgresDateFormat)
-
+	yyyyMMDDFormat := fmt.Sprintf("date=%s", tableData.LatestCDCTs.Format(ext.PostgresDateFormat))
 	if len(s.config.S3.FolderName) > 0 {
 		return strings.Join([]string{s.config.S3.FolderName, fqTableName, yyyyMMDDFormat}, "/")
 	}