From 72c83bd1cc3ce618908aa5c0d5b4ff6c8b8d7e8f Mon Sep 17 00:00:00 2001
From: Brage <bskjon@outlook.com>
Date: Mon, 24 Jul 2023 18:12:17 +0200
Subject: [PATCH] Printing collected events

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

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 0f3f413f..6c4636e0 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
@@ -104,6 +104,9 @@ 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" }}" }
+
         val referenceId = collection?.getRecords()?.firstOrNull()?.value()?.referenceId
         if (referenceId == null) {
             logger.warn { "referenceId is null, throwing collection" }