diff --git a/src/main/java/com/github/mmolimar/kafka/connect/fs/file/reader/ParquetFileReader.java b/src/main/java/com/github/mmolimar/kafka/connect/fs/file/reader/ParquetFileReader.java
index 0657d0b..0310550 100644
--- a/src/main/java/com/github/mmolimar/kafka/connect/fs/file/reader/ParquetFileReader.java
+++ b/src/main/java/com/github/mmolimar/kafka/connect/fs/file/reader/ParquetFileReader.java
@@ -90,7 +90,7 @@ public void seekFile(long offset) throws IOException {
             this.closed = false;
             setOffset(0);
         }
-        while (hasNext() && currentOffset() < offset) {
+        while (hasNextRecord() && currentOffset() < offset) {
             nextRecord();
         }
     }