@Override
    public Class<? extends Task> taskClass() {
        return FileStreamSourceTask.class;
    }
Very simple source connector that works with stdin or a file.
connect/file/src/main/java/org/apache/kafka/connect/file/FileStreamSourceConnector.java