diff --git a/Reader/build.gradle.kts b/Reader/build.gradle.kts index 67ae5025..401180f6 100644 --- a/Reader/build.gradle.kts +++ b/Reader/build.gradle.kts @@ -23,7 +23,7 @@ repositories { } dependencies { - implementation("no.iktdev.streamit.library:streamit-library-kafka:0.0.2-alpha17") + implementation("no.iktdev.streamit.library:streamit-library-kafka:0.0.2-alpha18") implementation("no.iktdev:exfl:0.0.4-SNAPSHOT") implementation("com.github.pgreze:kotlin-process:1.3.1") 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 f21974f0..3f43b736 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 @@ -54,6 +54,7 @@ class FileWatcher: FileWatcherEvents { object : EventMessageListener(CommonConfig.kafkaTopic, defaultConsumer, listOf(KnownEvents.REQUEST_FILE_READ.event)) { override fun onMessage(data: ConsumerRecord) { + if (data.value().status.statusType == StatusType.SUCCESS) { if (data.value().data is String) { val file = File(CommonConfig.incomingContent, data.value().data as String) diff --git a/Reader/src/main/kotlin/no/iktdev/streamit/content/reader/streams/StreamsReader.kt b/Reader/src/main/kotlin/no/iktdev/streamit/content/reader/streams/StreamsReader.kt index 6e63bbcc..87a0c939 100644 --- a/Reader/src/main/kotlin/no/iktdev/streamit/content/reader/streams/StreamsReader.kt +++ b/Reader/src/main/kotlin/no/iktdev/streamit/content/reader/streams/StreamsReader.kt @@ -30,7 +30,7 @@ class StreamsReader { init { object: EventMessageListener(CommonConfig.kafkaTopic, defaultConsumer, listOf(EVENT_READER_RECEIVED_FILE.event)) { override fun onMessage(data: ConsumerRecord) { - + logger.info { "RECORD: ${data.key()}" } if (data.value().status.statusType != StatusType.SUCCESS) { logger.info { "Ignoring event: ${data.key()} as status is not Success!" } return