diff --git a/src/main/java/com/github/jcustenborder/kafka/connect/spooldir/SpoolDirAvroSourceTask.java b/src/main/java/com/github/jcustenborder/kafka/connect/spooldir/SpoolDirAvroSourceTask.java
index a3d520a..1f9b4ef 100644
--- a/src/main/java/com/github/jcustenborder/kafka/connect/spooldir/SpoolDirAvroSourceTask.java
+++ b/src/main/java/com/github/jcustenborder/kafka/connect/spooldir/SpoolDirAvroSourceTask.java
@@ -48,6 +48,7 @@ protected void configure(InputFile inputFile, Long lastOffset) throws IOExceptio
     if (null != this.dataFileReader) {
       this.dataFileReader.close();
     }
+    datumReader = new GenericDatumReader<>();
     inputFile.startProcessing();
     this.dataFileReader = new DataFileReader<>(inputFile.file(), datumReader);
     this.recordOffset = 0;