diff --git a/docs/parameters/DynamoDBSourceParameters.md b/docs/parameters/DynamoDBSourceParameters.md
index 0f528b6..c0e6d90 100644
--- a/docs/parameters/DynamoDBSourceParameters.md
+++ b/docs/parameters/DynamoDBSourceParameters.md
@@ -119,7 +119,7 @@ The number of batches to process concurrently from each shard. The default value
 [schema.ts:42](https://github.com/distinction-dev/serverless-pipes/blob/adc1ce1b20b719d2e58f62a01c813e4ef9c57a5c/src/schema.ts#L42)
 
 
-### startingPosition (optional)
+### startingPosition
 
 • **startingPosition**: `string`
 
diff --git a/src/compiler.ts b/src/compiler.ts
index e49f5ca..fc10523 100644
--- a/src/compiler.ts
+++ b/src/compiler.ts
@@ -40,8 +40,7 @@ export function compileBasedOnSourceType(
     case "dynamodb": {
       const params: AWSPipesPipePipeSourceParametersDefinition = {
         DynamoDBStreamParameters: {
-          StartingPosition:
-            config.source[sourceName].parallelizationFactor || "",
+          StartingPosition: config.source[sourceName].startingPosition || "",
           BatchSize: config.source[sourceName]?.batchsize || 10,
           DeadLetterConfig: {
             Arn: config.source[sourceName]?.deadLetterArn || "",
@@ -63,8 +62,7 @@ export function compileBasedOnSourceType(
     case "kinesisStream": {
       const params: AWSPipesPipePipeSourceParametersDefinition = {
         KinesisStreamParameters: {
-          StartingPosition:
-            config.source[sourceName].parallelizationFactor || "",
+          StartingPosition: config.source[sourceName].startingPosition || "",
           BatchSize: config.source[sourceName]?.batchsize || 10,
           DeadLetterConfig: {
             Arn: config.source[sourceName]?.deadLetterArn || "",