protected static void waitForReplication(Table table, int expectedRows, int retries)
    throws IOException, InterruptedException {
    Scan scan;
    for (int i = 0; i < retries; i++) {
      scan = new Scan();
      if (i == retries - 1) {
        fail("Waited too much time for normal batch replication");
      }
      int count = 0;
      try (ResultScanner scanner = table.getScanner(scan)) {
        while (scanner.next() != null) {
          count++;
        }
      }
      if (count != expectedRows) {
        LOG.info("Only got " + count + " rows");
        Thread.sleep(SLEEP_TIME);
      } else {
        break;
      }
    }
  }
This class is only a base for other integration-level replication tests. Do not add tests here.
TestReplicationSmallTests is where tests that don't require bring machines up/down should go All
other tests should have their own classes and extend this one
hbase-server/src/test/java/org/apache/hadoop/hbase/replication/TestReplicationBase.java