@Override
  public void process(TabletInsertionEvent tabletInsertionEvent, EventCollector eventCollector)
      throws Exception {
    if (tabletInsertionEvent instanceof EnrichedEvent) {
      final EnrichedEvent enrichedEvent = (EnrichedEvent) tabletInsertionEvent;
      if (enrichedEvent.getReplicateIndexForIoTV2() != EnrichedEvent.NO_COMMIT_ID) {
        eventCollector.collect(tabletInsertionEvent);
      }
    }
  }
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