@Override
  public synchronized void onSuccess(final Boolean hasAtLeastOneEventProcessed) {
    final int totalRetryCount = retryCount.getAndSet(0);

    submitSelf();

    if (totalRetryCount != 0) {
      LOGGER.warn(
          "Successfully executed subtask {}({}) after {} retries.",
          taskID,
          this.getClass().getSimpleName(),
          totalRetryCount);
    }
  }
Try to consume an {@link Event} by the pipe plugin.

@return {@code true} if the {@link Event} is consumed successfully, {@code false} if no more
    {@link Event} can be consumed
@throws Exception if any error occurs when consuming the {@link Event}
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/task/subtask/PipeSubtask.java