@Override
  public void startReplicationService() throws IOException {
    this.replicationManager.init();
    this.server.getChoreService().scheduleChore(new ReplicationStatisticsChore(
      "ReplicationSourceStatistics", server, (int) TimeUnit.SECONDS.toMillis(statsPeriodInSecond)));
    LOG.info("{} started", this.server.toString());
  }
If replication is enabled and this cluster is a master, it starts
hbase-server/src/main/java/org/apache/hadoop/hbase/replication/regionserver/Replication.java