@Override
  public void onConfigurationChange(Configuration conf) {
    this.conf = conf;
    this.peerStorage = ReplicationStorageFactory.getReplicationPeerStorage(fs, zookeeper, conf);
    for (ReplicationPeerImpl peer : peerCache.values()) {
      try {
        peer.onConfigurationChange(
          ReplicationPeerConfigUtil.getPeerClusterConfiguration(conf, peer.getPeerConfig()));
      } catch (IOException e) {
        LOG.warn("failed to reload configuration for peer {}", peer.getId(), e);
      }
    }
  }
Helper method to connect to a peer
@param peerId peer's identifier
@return object representing the peer
hbase-replication/src/main/java/org/apache/hadoop/hbase/replication/ReplicationPeers.java