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