public void initialize(SourceTaskContext context) {
        this.context = context;
    }
Initialize this SourceTask with the specified context object.
connect/api/src/main/java/org/apache/kafka/connect/source/SourceTask.java