diff --git a/sdk/cosmos/microsoft-azure-cosmos/src/main/java/com/azure/data/cosmos/internal/query/DocumentProducer.java b/sdk/cosmos/microsoft-azure-cosmos/src/main/java/com/azure/data/cosmos/internal/query/DocumentProducer.java
index da5214c37dfd..19eb9e9b4acf 100644
--- a/sdk/cosmos/microsoft-azure-cosmos/src/main/java/com/azure/data/cosmos/internal/query/DocumentProducer.java
+++ b/sdk/cosmos/microsoft-azure-cosmos/src/main/java/com/azure/data/cosmos/internal/query/DocumentProducer.java
@@ -143,7 +143,7 @@ public DocumentProducer(
 
         this.correlatedActivityId = correlatedActivityId;
 
-        this.feedOptions = feedOptions != null ? feedOptions : new FeedOptions();
+        this.feedOptions = feedOptions != null ? new FeedOptions(feedOptions) : new FeedOptions();
         this.feedOptions.requestContinuation(initialContinuationToken);
         this.lastResponseContinuationToken = initialContinuationToken;
         this.resourceType = resourceType;
@@ -161,9 +161,9 @@ public Flux<DocumentProducerFeedResponse> produceAsync() {
                 .getPaginatedQueryResultAsObservable(
                         feedOptions.requestContinuation(),
                         sourcePartitionCreateRequestFunc,
-                        executeRequestFuncWithRetries, 
-                        resourceType, 
-                        top, 
+                        executeRequestFuncWithRetries,
+                        resourceType,
+                        top,
                         pageSize)
                 .map(rsp -> {
                     lastResponseContinuationToken = rsp.continuationToken();
@@ -220,7 +220,7 @@ private List<DocumentProducer<T>> createReplacingDocumentProducersOnSplit(List<P
         }
         return replacingDocumentProducers;
     }
-    
+
     protected DocumentProducer<T> createChildDocumentProducerOnSplit(
             PartitionKeyRange targetRange,
             String initialContinuationToken) {