From 7d1b05534ccbd67170efc70067a3b4027931db3f Mon Sep 17 00:00:00 2001 From: Sanketh Nalli Date: Fri, 10 May 2024 17:06:04 -0700 Subject: [PATCH] [DR] Set default recovery token-factory (#2774) [DR] Set default recovery token-factory --- .../main/java/com/github/ambry/config/ReplicationConfig.java | 5 +++-- 1 file changed, 3 insertions(+), 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 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 =