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

Printing collected events

Browse Source
This commit is contained in:
Brage 2023-07-24 18:12:17 +02:00
parent bb8f311ebb
commit 72c83bd1cc
1 changed files with 3 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -104,6 +104,9 @@ class EncodedStreams : DefaultKafkaReader("streamSelector"), ICollectedMessagesE
override fun onCollectionCompleted(collection: ResultCollection?) { override fun onCollectionCompleted(collection: ResultCollection?) {
logger.info { "Collection received" } 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 val referenceId = collection?.getRecords()?.firstOrNull()?.value()?.referenceId
if (referenceId == null) { if (referenceId == null) {
logger.warn { "referenceId is null, throwing collection" } logger.warn { "referenceId is null, throwing collection" }