iktdev/MediaProcessing
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Logging

Browse Source
This commit is contained in:
Brage 2023-07-24 18:54:39 +02:00
parent b4b2627b9e
commit 3e8d71c682
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
Reader/src/main/kotlin/no/iktdev/streamit/content/reader/analyzer/encoding/EncodedStreams.kt
View File

@ -108,7 +108,7 @@ class EncodedStreams : DefaultKafkaReader("streamSelector"), ICollectedMessagesE
if (collectedEvents.isEmpty()) { if (collectedEvents.isEmpty()) {
logger.error { "\nConsumer $subId collected: is null or empty!" } logger.error { "\nConsumer $subId collected: is null or empty!" }
} else { } 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 val referenceId = collection?.getRecords()?.firstOrNull()?.value()?.referenceId