diff --git a/ambry-api/src/main/java/com/github/ambry/config/ReplicationConfig.java b/ambry-api/src/main/java/com/github/ambry/config/ReplicationConfig.java
index f2319496c7..d63947a1ba 100644
--- a/ambry-api/src/main/java/com/github/ambry/config/ReplicationConfig.java
+++ b/ambry-api/src/main/java/com/github/ambry/config/ReplicationConfig.java
@@ -45,8 +45,9 @@ public class ReplicationConfig {
   /**
    * The factory class the replication uses to create cloud token
    */
+  public static final String DEFAULT_RECOVERY_TOKEN_FACTORY = "com.github.ambry.cloud.RecoveryTokenFactory";
   @Config(REPLICATION_CLOUD_TOKEN_FACTORY)
-  @Default("com.github.ambry.cloud.azure.CosmosUpdateTimeFindTokenFactory")
+  @Default(DEFAULT_RECOVERY_TOKEN_FACTORY)
   public final String replicationCloudTokenFactory;
 
   /**
@@ -325,7 +326,7 @@ public ReplicationConfig(VerifiableProperties verifiableProperties) {
     replicationStoreTokenFactory =
         verifiableProperties.getString("replication.token.factory", "com.github.ambry.store.StoreFindTokenFactory");
     replicationCloudTokenFactory = verifiableProperties.getString(REPLICATION_CLOUD_TOKEN_FACTORY,
-        "com.github.ambry.cloud.azure.CosmosChangeFeedFindTokenFactory");
+        DEFAULT_RECOVERY_TOKEN_FACTORY);
     replicationNumOfIntraDCReplicaThreads =
         verifiableProperties.getInt("replication.no.of.intra.dc.replica.threads", 1);
     replicationNumOfInterDCReplicaThreads =