HBASE-26029 It is not reliable to use nodeDeleted event to track regi…

…on server's death

hbase-protocol-shaded/src/main/protobuf/server/master/MasterProcedure.proto

@@ -312,8 +312,9 @@ enum ServerCrashState {
   SERVER_CRASH_WAIT_ON_ASSIGN = 9;
   SERVER_CRASH_SPLIT_META_LOGS = 10;
   SERVER_CRASH_ASSIGN_META = 11;
-  SERVER_CRASH_DELETE_SPLIT_META_WALS_DIR=12;
-  SERVER_CRASH_DELETE_SPLIT_WALS_DIR=13;
+  SERVER_CRASH_DELETE_SPLIT_META_WALS_DIR = 12;
+  SERVER_CRASH_DELETE_SPLIT_WALS_DIR = 13;
+  SERVER_CRASH_CLAIM_REPLICATION_QUEUES = 14;
   SERVER_CRASH_HANDLE_RIT2 = 20[deprecated=true];
   SERVER_CRASH_FINISH = 100;
 }
@@ -624,3 +625,23 @@ enum SplitWALState{
   DISPATCH_WAL_TO_WORKER = 2;
   RELEASE_SPLIT_WORKER = 3;
 }
+
+message ClaimReplicationQueuesStateData {
+  required ServerName crashed_server = 1;
+}
+
+message ClaimReplicationQueueRemoteStateData {
+  required ServerName crashed_server = 1;
+  required string queue = 2;
+  required ServerName target_server = 3;
+}
+
+message ClaimReplicationQueueRemoteParameter {
+  required ServerName crashed_server = 1;
+  required string queue = 2;
+}
+
+enum ClaimReplicationQueuesState {
+  CLAIM_REPLICATION_QUEUES_DISPATCH = 1;
+  CLAIM_REPLICATION_QUEUES_FINISH = 2;
+}

hbase-replication/src/main/java/org/apache/hadoop/hbase/replication/ReplicationFactory.java

@@ -18,7 +18,6 @@
 package org.apache.hadoop.hbase.replication;
 
 import org.apache.hadoop.conf.Configuration;
-import org.apache.hadoop.hbase.util.ReflectionUtils;
 import org.apache.hadoop.hbase.zookeeper.ZKWatcher;
 import org.apache.yetus.audience.InterfaceAudience;
 
@@ -36,10 +35,4 @@ private ReplicationFactory() {
   public static ReplicationPeers getReplicationPeers(ZKWatcher zk, Configuration conf) {
     return new ReplicationPeers(zk, conf);
   }
-
-  public static ReplicationTracker getReplicationTracker(ReplicationTrackerParams params) {
-    Class<? extends ReplicationTracker> clazz = params.conf().getClass(REPLICATION_TRACKER_IMPL,
-      ZKReplicationTracker.class, ReplicationTracker.class);
-    return ReflectionUtils.newInstance(clazz, params);
-  }
 }