@Override
        public List<SourceRecord> poll() {
            return null;
        }
This method is called in place of methods on WorkerTask subclasses.
connect/runtime/src/test/java/org/apache/kafka/connect/runtime/WorkerTest.java