From 31223e4c1e54e5fbca9352f78defb435fb3db4d3 Mon Sep 17 00:00:00 2001
From: Jake Dorne <hello@jakedorne.com>
Date: Mon, 7 Nov 2022 11:39:27 +1300
Subject: [PATCH] Fix batching on parquet file reader

---
 .../kafka/connect/fs/file/reader/ParquetFileReader.java         | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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();
         }
     }