diff --git a/Reader/src/main/kotlin/no/iktdev/streamit/content/reader/collector/VideoConsumer.kt b/Reader/src/main/kotlin/no/iktdev/streamit/content/reader/collector/VideoConsumer.kt index fb139450..25834e8a 100644 --- a/Reader/src/main/kotlin/no/iktdev/streamit/content/reader/collector/VideoConsumer.kt +++ b/Reader/src/main/kotlin/no/iktdev/streamit/content/reader/collector/VideoConsumer.kt @@ -87,9 +87,14 @@ class VideoConsumer: DefaultKafkaReader("collectorConsumerEncodedVideo"), IColle val coverFile = metadata?.cover?.let { coverUrl -> runBlocking { try { - Downloader(coverUrl, CommonConfig.outgoingContent, fileData.title).download() + val _file = Downloader(coverUrl, CommonConfig.outgoingContent, fileData.title).download() + if (_file == null || !_file.exists()) { + logger.info { "Failed to download the file" } + } + _file } catch (e: Exception) { // No cover + e.printStackTrace() null } }