private boolean transferInEventWithoutCheck(PipeInsertionEvent tabletInsertionEvent)
      throws Exception {
    // tabletInsertionEvent instanceof PipeInsertNodeTabletInsertionEvent)
    final PipeInsertNodeTabletInsertionEvent pipeInsertNodeTabletInsertionEvent =
        (PipeInsertNodeTabletInsertionEvent) tabletInsertionEvent;
    // We increase the reference count for this event to determine if the event may be released.
    if (!pipeInsertNodeTabletInsertionEvent.increaseReferenceCount(
        PipeConsensusAsyncConnector.class.getName())) {
      return false;
    }

    TCommitId tCommitId;
    TConsensusGroupId tConsensusGroupId =
        new TConsensusGroupId(TConsensusGroupType.DataRegion, consensusGroupId);
    tCommitId =
        new TCommitId(
            pipeInsertNodeTabletInsertionEvent.getReplicateIndexForIoTV2(),
            pipeInsertNodeTabletInsertionEvent.getCommitterKey().getRestartTimes(),
            pipeInsertNodeTabletInsertionEvent.getRebootTimes());

    final InsertNode insertNode =
        pipeInsertNodeTabletInsertionEvent.getInsertNodeViaCacheIfPossible();
    final ProgressIndex progressIndex = pipeInsertNodeTabletInsertionEvent.getProgressIndex();
    final TPipeConsensusTransferReq pipeConsensusTransferReq =
        Objects.isNull(insertNode)
            ? PipeConsensusTabletBinaryReq.toTPipeConsensusTransferReq(
                pipeInsertNodeTabletInsertionEvent.getByteBuffer(),
                tCommitId,
                tConsensusGroupId,
                progressIndex,
                thisDataNodeId)
            : PipeConsensusTabletInsertNodeReq.toTPipeConsensusTransferReq(
                insertNode, tCommitId, tConsensusGroupId, progressIndex, thisDataNodeId);
    final PipeConsensusTabletInsertNodeEventHandler pipeConsensusInsertNodeReqHandler =
        new PipeConsensusTabletInsertNodeEventHandler(
            pipeInsertNodeTabletInsertionEvent,
            pipeConsensusTransferReq,
            this,
            pipeConsensusConnectorMetrics);

    transfer(pipeConsensusInsertNodeReqHandler);
    return true;
  }
if one event is successfully processed by receiver in PipeConsensus, we will remove this event
from transferBuffer in order to transfer other event.
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol/pipeconsensus/PipeConsensusAsyncConnector.java