From fc710fa771e265841957b4b125b5f85090ae64e6 Mon Sep 17 00:00:00 2001 From: Julien Fontaine Date: Fri, 3 Jul 2020 12:07:56 -0400 Subject: Add error handling for CDS Kafka Producer callback Issue-ID: CCSDK-2522 Signed-off-by: Julien Fontaine Change-Id: Ia7aabaa6d978a13fbf657ea6b406e0b37bc02222 --- .../blueprintsprocessor/message/service/KafkaMessageProducerService.kt | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) (limited to 'ms/blueprintsprocessor/modules/commons') 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 -- cgit 1.2.3-korg