diff --git a/Reader/build.gradle.kts b/Reader/build.gradle.kts
index 137002d5..de648643 100644
--- a/Reader/build.gradle.kts
+++ b/Reader/build.gradle.kts
@@ -23,7 +23,7 @@ repositories {
 }
 
 dependencies {
-    implementation("no.iktdev.streamit.library:streamit-library-kafka:0.0.2-alpha67")
+    implementation("no.iktdev.streamit.library:streamit-library-kafka:0.0.2-alpha68")
     implementation("no.iktdev:exfl:0.0.12-SNAPSHOT")
 
     implementation("no.iktdev.streamit.library:streamit-library-db:0.0.6-alpha7")
diff --git a/Reader/src/main/kotlin/no/iktdev/streamit/content/reader/analyzer/encoding/EncodedStreams.kt b/Reader/src/main/kotlin/no/iktdev/streamit/content/reader/analyzer/encoding/EncodedStreams.kt
index f571b420..1318525f 100644
--- a/Reader/src/main/kotlin/no/iktdev/streamit/content/reader/analyzer/encoding/EncodedStreams.kt
+++ b/Reader/src/main/kotlin/no/iktdev/streamit/content/reader/analyzer/encoding/EncodedStreams.kt
@@ -31,7 +31,8 @@ class EncodedStreams : DefaultKafkaReader("streamSelector"), ICollectedMessagesE
         consumer = defaultConsumer,
         initiatorEvent = KafkaEvents.EVENT_READER_RECEIVED_FILE,
         completionEvent = KafkaEvents.EVENT_READER_DETERMINED_FILENAME,
-        listener = this
+        listener = this,
+        eventCollectionClass = ResultCollection::class.java
     )
 
     init {