@Override
  public void init(Context context) throws IOException {
    super.init(context);
    this.conf = HBaseConfiguration.create(ctx.getConfiguration());
    this.clusterURI = ConnectionRegistryFactory
      .tryParseAsConnectionURI(context.getReplicationPeer().getPeerConfig().getClusterKey());
    this.ratio =
      ctx.getConfiguration().getFloat("replication.source.ratio", DEFAULT_REPLICATION_SOURCE_RATIO);
    this.badSinkThreshold =
      ctx.getConfiguration().getInt("replication.bad.sink.threshold", DEFAULT_BAD_SINK_THRESHOLD);
    this.badReportCounts = Maps.newHashMap();
  }
Some implementations of HBaseInterClusterReplicationEndpoint may require instantiate different
Connection implementations, or initialize it in a different way, so defining createConnection
as protected for possible overridings.
hbase-server/src/main/java/org/apache/hadoop/hbase/replication/HBaseReplicationEndpoint.java