public synchronized void clearRetryEventsReferenceCount() {
    while (!retryEventQueue.isEmpty()) {
      final EnrichedEvent event = retryEventQueue.poll();
      event.clearReferenceCount(PipeConsensusAsyncConnector.class.getName());
    }
  }
Add failure events to retry queue.

@param events events to retry
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol/pipeconsensus/PipeConsensusAsyncConnector.java