public synchronized void maybeThrowAsyncError() {
        if (taskPutException.get() != null && !retryWithToleranceOperator.withinToleranceLimits()) {
            throw new ConnectException("Tolerance exceeded in error handler", taskPutException.get());
        }
    }
Cancels all active error reports for a given set of topic partitions
@param topicPartitions the topic partitions to cancel reporting for
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/errors/WorkerErrantRecordReporter.java