Handle exceptions while processing files better

Now only commit offsets for a file if the entire file is processed without errors, this ensures we process every record and do not miss records

src/main/java/com/github/mmolimar/kafka/connect/fs/FsSourceTask.java

@@ -102,6 +102,7 @@ public List<SourceRecord> poll() {
                     } catch (ConnectException | IOException e) {
                         //when an exception happens reading a file, the connector continues
                         log.error("Error reading file [{}]. Keep going...", metadata.getPath(), e);
+                        return new ArrayList<SourceRecord>().stream();
                     }
                     log.debug("Read [{}] records from file [{}].", records.size(), metadata.getPath());