Corrected offset. fixes #40

jcustenborder · Mar 27, 2018 · 7b36790 · 7b36790
1 parent 1a52576
commit 7b36790
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/main/java/com/github/jcustenborder/kafka/connect/spooldir/SpoolDirJsonSourceTask.java b/src/main/java/com/github/jcustenborder/kafka/connect/spooldir/SpoolDirJsonSourceTask.java
@@ -61,7 +61,7 @@ protected void configure(InputStream inputStream, Map<String, String> metadata,
 
     if (null != lastOffset) {
       int skippedRecords = 0;
-      while (this.iterator.hasNext() && skippedRecords < lastOffset) {
+      while (this.iterator.hasNext() && skippedRecords <= lastOffset) {
         next();
         skippedRecords++;
       }
@@ -77,7 +77,7 @@ JsonNode next() {
   }
 
   @Override
-  protected List<SourceRecord> process() throws IOException {
+  protected List<SourceRecord> process() {
     List<SourceRecord> records = new ArrayList<>(this.config.batchSize);
 
     while (this.iterator.hasNext() && records.size() < this.config.batchSize) {