From b4b2627b9e15a318dfaf238744e41394c17f31ee Mon Sep 17 00:00:00 2001
From: Brage <bskjon@outlook.com>
Date: Mon, 24 Jul 2023 18:38:15 +0200
Subject: [PATCH] Logging

---
 .../content/reader/analyzer/encoding/EncodedStreams.kt      | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git a/Reader/src/main/kotlin/no/iktdev/streamit/content/reader/analyzer/encoding/EncodedStreams.kt b/Reader/src/main/kotlin/no/iktdev/streamit/content/reader/analyzer/encoding/EncodedStreams.kt
index 6c4636e0..f52c58b5 100644
--- a/Reader/src/main/kotlin/no/iktdev/streamit/content/reader/analyzer/encoding/EncodedStreams.kt
+++ b/Reader/src/main/kotlin/no/iktdev/streamit/content/reader/analyzer/encoding/EncodedStreams.kt
@@ -105,7 +105,11 @@ class EncodedStreams : DefaultKafkaReader("streamSelector"), ICollectedMessagesE
     override fun onCollectionCompleted(collection: ResultCollection?) {
         logger.info { "Collection received" }
         val collectedEvents = collection?.getRecords()?.map { it.key() }?.toList() ?: emptyList()
-        logger.info { "\nConsumer $subId collected:\n${collectedEvents.joinToString { "\n\t" }}" }
+        if (collectedEvents.isEmpty()) {
+            logger.error { "\nConsumer $subId collected: is null or empty!" }
+        } else {
+            logger.info { "\nConsumer $subId collected:\n${collectedEvents.joinToString { "\n\t" }}" }
+        }
 
         val referenceId = collection?.getRecords()?.firstOrNull()?.value()?.referenceId
         if (referenceId == null) {