diff --git a/src/DocumentDB.ChangeFeedProcessor/FeedProcessing/PartitionProcessorFactory.cs b/src/DocumentDB.ChangeFeedProcessor/FeedProcessing/PartitionProcessorFactory.cs
index 71cf64f..06cdfbb 100644
--- a/src/DocumentDB.ChangeFeedProcessor/FeedProcessing/PartitionProcessorFactory.cs
+++ b/src/DocumentDB.ChangeFeedProcessor/FeedProcessing/PartitionProcessorFactory.cs
@@ -37,9 +37,7 @@ public IPartitionProcessor Create(ILease lease, IChangeFeedObserver observer)
             var settings = new ProcessorSettings
             {
                 CollectionSelfLink = this.collectionSelfLink,
-                RequestContinuation = !string.IsNullOrEmpty(lease.ContinuationToken) ?
-                    lease.ContinuationToken :
-                    this.changeFeedProcessorOptions.RequestContinuation,
+                RequestContinuation = this.changeFeedProcessorOptions.StartFromBeginning ? "0" : lease.ContinuationToken,
                 PartitionKeyRangeId = lease.PartitionId,
                 FeedPollDelay = this.changeFeedProcessorOptions.FeedPollDelay,
                 MaxItemCount = this.changeFeedProcessorOptions.MaxItemCount,