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