@BeforeClass
  public static void setUp() throws Exception {
    UTIL.startMiniCluster(3);
    // notice that we do not need to set replication scope here, EmptyReplicationEndpoint take all
    // edits no matter what the replications scope is.
    UTIL.createTable(TABLE_NAME, CF);
    UTIL.getAdmin().addReplicationPeer(PEER_ID,
      ReplicationPeerConfig.newBuilder().setClusterKey("zk1:8888:/hbase")
        .setReplicationEndpointImpl(EndpointForTest.class.getName()).build());
  }
Confirm that the empty replication endpoint can work.
hbase-server/src/test/java/org/apache/hadoop/hbase/replication/TestVerifyCellsReplicationEndpoint.java