public void executingClass(Class<?> klass) {
        this.klass = klass;
    }
@param klass set the class which is currently executing.
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/errors/ProcessingContext.java