public Stage stage() {
        return position;
    }
@return the stage in the connector pipeline which is currently executing.
connect/runtime/src/main/java/org/apache/kafka/connect/runtime/errors/ProcessingContext.java