@Override
  public Cell filterCell(final Entry entry, Cell cell) {
    ExtendedCell extendedCell = PrivateCellUtil.ensureExtendedCell(cell);
    ReplicationPeerConfig peerConfig = this.peer.getPeerConfig();
    TableName tableName = entry.getKey().getTableName();
    if (CellUtil.matchingColumn(cell, WALEdit.METAFAMILY, WALEdit.BULK_LOAD)) {
      // If the cell is about BULKLOAD event, unpack and filter it by BulkLoadCellFilter.
      return bulkLoadFilter.filterCell(extendedCell,
        fam -> !peerConfig.needToReplicate(tableName, fam));
    } else {
      return peerConfig.needToReplicate(tableName, CellUtil.cloneFamily(cell)) ? cell : null;
    }
  }
Filter a WAL Entry by the peer config according to the table and family which it belongs to.
@see ReplicationPeerConfig#needToReplicate(TableName, byte[])
hbase-server/src/main/java/org/apache/hadoop/hbase/replication/NamespaceTableCfWALEntryFilter.java