X-Git-Url: https://gerrit.onap.org/r/gitweb?a=blobdiff_plain;f=ms%2Fblueprintsprocessor%2Fmodules%2Fcommons%2Fmessage-lib%2Fsrc%2Fmain%2Fkotlin%2Forg%2Fonap%2Fccsdk%2Fcds%2Fblueprintsprocessor%2Fmessage%2Fservice%2FKafkaMessageProducerService.kt;fp=ms%2Fblueprintsprocessor%2Fmodules%2Fcommons%2Fmessage-lib%2Fsrc%2Fmain%2Fkotlin%2Forg%2Fonap%2Fccsdk%2Fcds%2Fblueprintsprocessor%2Fmessage%2Fservice%2FKafkaMessageProducerService.kt;h=8de1f05be3abd13a3d50f752fd384461cbbd5829;hb=fc710fa771e265841957b4b125b5f85090ae64e6;hp=e4991d2d872265ea33481909ceb4c7a3ec565150;hpb=01e3ff777b995767311be29ad51ebba53cb054c2;p=ccsdk%2Fcds.git

diff --git a/ms/blueprintsprocessor/modules/commons/message-lib/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/message/service/KafkaMessageProducerService.kt b/ms/blueprintsprocessor/modules/commons/message-lib/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/message/service/KafkaMessageProducerService.kt
index e4991d2d8..8de1f05be 100644
--- a/ms/blueprintsprocessor/modules/commons/message-lib/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/message/service/KafkaMessageProducerService.kt
+++ b/ms/blueprintsprocessor/modules/commons/message-lib/src/main/kotlin/org/onap/ccsdk/cds/blueprintsprocessor/message/service/KafkaMessageProducerService.kt
@@ -79,7 +79,8 @@ class KafkaMessageProducerService(
             headers.forEach { (key, value) -> recordHeaders.add(RecordHeader(key, value.toByteArray())) }
         }
         val callback = Callback { metadata, exception ->
-            log.trace("message published to(${metadata.topic()}), offset(${metadata.offset()}), headers :$headers")
+            if (exception == null) log.trace("message published to(${metadata.topic()}), offset(${metadata.offset()}), headers :$headers")
+            else log.error("ERROR : ${exception.message}")
         }
         messageTemplate().send(record, callback)
         return true