diff --git a/Reader/build.gradle.kts b/Reader/build.gradle.kts
index f63967c6..bca1066b 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-alpha42")
+    implementation("no.iktdev.streamit.library:streamit-library-kafka:0.0.2-alpha43")
     implementation("no.iktdev:exfl:0.0.6-SNAPSHOT")
 
 
diff --git a/Reader/src/main/kotlin/no/iktdev/streamit/content/reader/analyzer/EncodedStreams.kt b/Reader/src/main/kotlin/no/iktdev/streamit/content/reader/analyzer/EncodedStreams.kt
index 35aab391..908e45c2 100644
--- a/Reader/src/main/kotlin/no/iktdev/streamit/content/reader/analyzer/EncodedStreams.kt
+++ b/Reader/src/main/kotlin/no/iktdev/streamit/content/reader/analyzer/EncodedStreams.kt
@@ -78,7 +78,7 @@ class EncodedStreams : ISequentialMessageEvent {
         logger.info { "All messages are received" }
         val baseMessage = result[KnownEvents.EVENT_READER_RECEIVED_FILE.event]
         if (baseMessage == null) {
-            produceErrorMessage(Message(referenceId = referenceId, status = Status(statusType = StatusType.ERROR)), "No base message found!")
+            produceErrorMessage(Message(referenceId = referenceId, status = Status(statusType = StatusType.ERROR)), "Initiator message not found!")
             return
         }