public Class<?> executingClass() {
        return klass;
    }
@return the class which is going to execute the current operation.
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/errors/ProcessingContext.java