From 35d0498493f415bed37600cfac28c07c2ce2a6fc Mon Sep 17 00:00:00 2001
From: Brage <bskjon@outlook.com>
Date: Tue, 18 Jul 2023 22:34:35 +0200
Subject: [PATCH] Logging

---
 .../no/iktdev/streamit/content/reader/streams/StreamsReader.kt | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

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 87a0c939..d64d6bb4 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
@@ -31,6 +31,7 @@ class StreamsReader {
         object: EventMessageListener(CommonConfig.kafkaTopic, defaultConsumer, listOf(EVENT_READER_RECEIVED_FILE.event)) {
             override fun onMessage(data: ConsumerRecord<String, Message>) {
                 logger.info { "RECORD: ${data.key()}" }
+                logger.info { "Active filters: ${this.acceptsEvents.joinToString(",") }}" }
                 if (data.value().status.statusType != StatusType.SUCCESS) {
                     logger.info { "Ignoring event: ${data.key()} as status is not Success!" }
                     return
@@ -38,7 +39,7 @@ class StreamsReader {
                 val dataValue = data.value().dataAs(FileWatcher.FileResult::class.java)
 
                 if (dataValue == null) {
-                    logger.info { "Ignoring event: ${data.key()} as values is not of expected type!, ${data.value().data}" }
+                    logger.info { "Ignoring event: ${data.key()} as values is not of expected type!" }
                     return
                 }
                 logger.info { "Preparing Probe for ${dataValue.file}" }