@Override
  public void process(TsFileInsertionEvent tsFileInsertionEvent, EventCollector eventCollector)
      throws Exception {
    if (tsFileInsertionEvent instanceof EnrichedEvent
        && ((EnrichedEvent) tsFileInsertionEvent).getReplicateIndexForIoTV2()
            != EnrichedEvent.NO_COMMIT_ID) {
      eventCollector.collect(tsFileInsertionEvent);
    }
  }
Judge whether a given event should be replicated or sent by consensus pipe. Only events that
pass this check can be assigned a specific value for `EnrichedEvent.replicateIndexForIoTV2`

@param enrichedEvent
@return true if event is totally generated by client operation instead of consensus
    replication.
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/processor/pipeconsensus/PipeConsensusProcessor.java