diff --git a/sources/dynamodb/dynamodb.go b/sources/dynamodb/dynamodb.go
index 50159f03..4fb6c10c 100644
--- a/sources/dynamodb/dynamodb.go
+++ b/sources/dynamodb/dynamodb.go
@@ -44,7 +44,7 @@ func Load(cfg config.DynamoDB) (sources.Source, bool, error) {
 			cfg:       &cfg,
 			storage:   offsets.NewStorage(cfg.OffsetFile, nil, nil),
 			streams:   dynamodbstreams.NewFromConfig(_awsCfg),
-			shardChan: make(chan *types.Shard),
+			shardChan: make(chan types.Shard),
 		}, true, nil
 	}
 }