@Override
    public synchronized void close() {
        ConnectException e = null;
        for (ErrorReporter<T> reporter : reporters) {
            try {
                reporter.close();
            } catch (Throwable t) {
                e = e != null ? e : new ConnectException("Failed to close all reporters");
                e.addSuppressed(t);
            }
        }
        reporters = Collections.emptyList();
        if (e != null) {
            throw e;
        }
    }
This will stop any further retries for operations.
This will also mark any ongoing operations that are currently backing off for retry as failed.
This can be called from a separate thread to break out of retry/backoff loops in
{@link #execAndRetry(ProcessingContext, Operation)}
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/errors/RetryWithToleranceOperator.java