From 6359d39a7205634d77d416fefabd8b4eb6ff91f2 Mon Sep 17 00:00:00 2001 From: Brage Date: Mon, 17 Jul 2023 01:07:11 +0200 Subject: [PATCH] Updated requirments --- .../java/no/iktdev/streamit/content/common/CommonConfig.kt | 2 +- .../iktdev/streamit/content/reader/fileWatcher/FileWatcher.kt | 2 +- pyMetadata/requirements.txt | 3 ++- 3 files changed, 4 insertions(+), 3 deletions(-) diff --git a/CommonCode/src/main/java/no/iktdev/streamit/content/common/CommonConfig.kt b/CommonCode/src/main/java/no/iktdev/streamit/content/common/CommonConfig.kt index 697fb7b7..1fb3dda8 100644 --- a/CommonCode/src/main/java/no/iktdev/streamit/content/common/CommonConfig.kt +++ b/CommonCode/src/main/java/no/iktdev/streamit/content/common/CommonConfig.kt @@ -3,7 +3,7 @@ package no.iktdev.streamit.content.common import java.io.File object CommonConfig { - var kafkaConsumerId: String = System.getenv("KAFKA_TOPIC") ?: "contentEvents" + var kafkaTopic: String = System.getenv("KAFKA_TOPIC") ?: "contentEvents" var incomingContent: File? = if (!System.getenv("DIRECTORY_CONTENT_INCOMING").isNullOrEmpty()) File(System.getenv("DIRECTORY_CONTENT_INCOMING")) else null } \ No newline at end of file diff --git a/Reader/src/main/kotlin/no/iktdev/streamit/content/reader/fileWatcher/FileWatcher.kt b/Reader/src/main/kotlin/no/iktdev/streamit/content/reader/fileWatcher/FileWatcher.kt index 873430b4..aea2f0c3 100644 --- a/Reader/src/main/kotlin/no/iktdev/streamit/content/reader/fileWatcher/FileWatcher.kt +++ b/Reader/src/main/kotlin/no/iktdev/streamit/content/reader/fileWatcher/FileWatcher.kt @@ -20,7 +20,7 @@ import org.springframework.stereotype.Service private val logger = KotlinLogging.logger {} @Service class FileWatcher: FileWatcherEvents { - val messageProducer = DefaultProducer(CommonConfig.kafkaConsumerId) + val messageProducer = DefaultProducer(CommonConfig.kafkaTopic) val queue = FileWatcherQueue() diff --git a/pyMetadata/requirements.txt b/pyMetadata/requirements.txt index f0f85313..189a56aa 100644 --- a/pyMetadata/requirements.txt +++ b/pyMetadata/requirements.txt @@ -1,4 +1,5 @@ cinemagoer>=2023.5.1 AnilistPython>=0.1.3 kafka-python>=2.0.2 -fuzzywuzzy>=0.18.0 \ No newline at end of file +fuzzywuzzy>=0.18.0 +requests>=2.31.0 \ No newline at end of file