public Throwable error() {
        return error;
    }
@return the error (if any) which was encountered while processing the current stage.
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/errors/ProcessingContext.java