[DR] Set default recovery token-factory (linkedin#2774)

[DR] Set default recovery token-factory
justinlin-linkedin · May 11, 2024 · 7d1b055 · 7d1b055
1 parent e20e7bf
commit 7d1b055
Showing 1 changed file with 3 additions and 2 deletions.
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
@@ -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 =