iktdev/MediaProcessing
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Updated requirments

Browse Source
This commit is contained in:
Brage 2023-07-17 01:07:11 +02:00
parent 2b590a0f3a
commit 6359d39a72
3 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
CommonCode/src/main/java/no/iktdev/streamit/content/common/CommonConfig.kt
View File

@ -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
}

2
Reader/src/main/kotlin/no/iktdev/streamit/content/reader/fileWatcher/FileWatcher.kt
View File

@ -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()

1
pyMetadata/requirements.txt
View File

@ -2,3 +2,4 @@ cinemagoer>=2023.5.1
AnilistPython>=0.1.3
kafka-python>=2.0.2
fuzzywuzzy>=0.18.0
requests>=2.31.0