log file path

Signed-off-by: Sebastian Schüpbach <sebastian.schuepbach@unibas.ch>

src/main/kotlin/KafkaTopology.kt

@@ -27,6 +27,7 @@ import org.apache.jena.rdf.model.ResourceFactory
 import org.apache.jena.riot.RiotException
 import org.apache.kafka.streams.StreamsBuilder
 import org.apache.kafka.streams.kstream.Predicate
+import org.apache.logging.log4j.LogManager
 import org.memobase.rdf.EBUCORE
 import org.memobase.rdf.RDF
 import org.memobase.rdf.RICO
@@ -39,6 +40,7 @@ import settings.HeaderMetadata
 
 class KafkaTopology(private val settings: SettingsLoader) {
     private val appSettings = settings.appSettings
+    private val log = LogManager.getLogger("KafkaTopology")
 
     private val sftpClient = SftpClient(settings.sftpSettings)
     private val previewImageHandler = PreviewImageHandler(sftpClient)
@@ -239,6 +241,7 @@ class KafkaTopology(private val settings: SettingsLoader) {
 
                         for (extension in fileExtensions) {
                             val filePath = "$sftpBasePath/${data.first.second.recordSetId}/$type/$value.$extension"
+                            log.warn(filePath)
                             if (sftpClient.exists(filePath)) {
                                 link = "${Constant.sftpPathPrefix}$filePath"
                                 if (type == Constant.mediaFolderName) {