From 3e8d71c682e5e1ca7287eb30cac63be326884412 Mon Sep 17 00:00:00 2001 From: Brage Date: Mon, 24 Jul 2023 18:54:39 +0200 Subject: [PATCH] Logging --- .../streamit/content/reader/analyzer/encoding/EncodedStreams.kt | 2 +- 1 file changed, 1 insertion(+), 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 f52c58b5..1247b548 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 @@ -108,7 +108,7 @@ class EncodedStreams : DefaultKafkaReader("streamSelector"), ICollectedMessagesE if (collectedEvents.isEmpty()) { logger.error { "\nConsumer $subId collected: is null or empty!" } } else { - logger.info { "\nConsumer $subId collected:\n${collectedEvents.joinToString { "\n\t" }}" } + logger.info { "\nConsumer $subId collected:\n ${collectedEvents.joinToString("\n\t")}" } } val referenceId = collection?.getRecords()?.firstOrNull()?.value()?.referenceId