diff --git a/Reader/src/main/kotlin/no/iktdev/streamit/content/reader/collector/EncodedVideoConsumer.kt b/Reader/src/main/kotlin/no/iktdev/streamit/content/reader/collector/EncodedVideoConsumer.kt
index 4b1d5df8..03b81145 100644
--- a/Reader/src/main/kotlin/no/iktdev/streamit/content/reader/collector/EncodedVideoConsumer.kt
+++ b/Reader/src/main/kotlin/no/iktdev/streamit/content/reader/collector/EncodedVideoConsumer.kt
@@ -56,7 +56,7 @@ class EncodedVideoConsumer: DefaultKafkaReader("collectorConsumerEncodedVideo"),
         val encodeWork = collection?.getEncodeWork()
         val serieData = collection?.getSerieInfo()
         val movieData = collection?.getMovieInfo()
-
+        logger.info { "Obtained collection: \n\t${collection?.getRecords()?.map { it.key() }?.joinToString("\n\t")}" }
 
         if (fileData == null || encodeWork == null || collection.getReferenceId() == null) {
             logger.error { "Required data is null, as it has either status as non successful or simply missing" }
diff --git a/Reader/src/main/kotlin/no/iktdev/streamit/content/reader/collector/ExtractedSubtitleConsumer.kt b/Reader/src/main/kotlin/no/iktdev/streamit/content/reader/collector/ExtractedSubtitleConsumer.kt
index edce3dda..49828125 100644
--- a/Reader/src/main/kotlin/no/iktdev/streamit/content/reader/collector/ExtractedSubtitleConsumer.kt
+++ b/Reader/src/main/kotlin/no/iktdev/streamit/content/reader/collector/ExtractedSubtitleConsumer.kt
@@ -43,7 +43,7 @@ class ExtractedSubtitleConsumer : DefaultKafkaReader("collectorConsumerExtracted
             val message = Message(referenceId = data.value()?.referenceId ?: "M.I.A", status = Status(statusType = StatusType.SUCCESS))
 
             if (status) {
-                produceMessage(KafkaEvents.EVENT_COLLECTOR_VIDEO_STORED, message, null)
+                produceMessage(KafkaEvents.EVENT_COLLECTOR_SUBTITLE_STORED, message, null)
                 logger.info { "Stored ${File(workResult.outFile).absolutePath} subtitle" }
             } else {
                 produceErrorMessage(KafkaEvents.EVENT_COLLECTOR_SUBTITLE_STORED, message.withNewStatus(status = Status(statusType = StatusType.ERROR)), "Unknown, see log")