Issue-ID: CCSDK-2522
Signed-off-by: Julien Fontaine <julien.fontaine@bell.ca>
Change-Id: Ia7aabaa6d978a13fbf657ea6b406e0b37bc02222
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