@Test
  public void test() throws Exception {
    try (Table table = UTIL.getConnection().getTable(TABLE_NAME)) {
      for (int i = 0; i < 100; i++) {
        table.put(new Put(Bytes.toBytes(i)).addColumn(CF, CQ, Bytes.toBytes(i)));
      }
    }
    long lastNoCellTime = -1;
    for (int i = 0; i < 100;) {
      Cell cell = CELLS.poll();
      if (cell == null) {
        if (lastNoCellTime < 0) {
          lastNoCellTime = System.nanoTime();
        } else {
          if (System.nanoTime() - lastNoCellTime >= TimeUnit.SECONDS.toNanos(30)) {
            throw new TimeoutException("Timeout waiting for wal edit");
          }
        }
        Thread.sleep(1000);
        continue;
      }
      lastNoCellTime = -1;
      if (!Bytes.equals(CF, CellUtil.cloneFamily(cell))) {
        // meta edits, such as open/close/flush, etc. skip
        continue;
      }
      assertArrayEquals(Bytes.toBytes(i), CellUtil.cloneRow(cell));
      assertArrayEquals(CQ, CellUtil.cloneQualifier(cell));
      assertArrayEquals(Bytes.toBytes(i), CellUtil.cloneValue(cell));
      i++;
    }
  }
Confirm that the empty replication endpoint can work.
hbase-server/src/test/java/org/apache/hadoop/hbase/replication/TestVerifyCellsReplicationEndpoint.java