@Override
    public boolean alterOffsets(Map<String, String> connectorConfig, Map<TopicPartition, Long> offsets) {
        // Nothing to do here since FileStreamSinkConnector does not manage offsets externally nor does it require any
        // custom offset validation
        return true;
    }
Very simple sink connector that works with stdout or a file.
connect/file/src/main/java/org/apache/kafka/connect/file/FileStreamSinkConnector.java