From 64b1fe979862099dc067aa7a08a3429fdd95ee89 Mon Sep 17 00:00:00 2001 From: ichupin Date: Mon, 8 Jul 2024 12:46:21 +0200 Subject: [PATCH] Add logging for KafkaProducer The log message now does not contain the kafka message body itself, since it might be too big for kibana. Now along with the other information the log contains the message symbol length. --- .../floodlight/service/kafka/KafkaProducerService.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src-java/floodlight-service/floodlight-modules/src/main/java/org/openkilda/floodlight/service/kafka/KafkaProducerService.java b/src-java/floodlight-service/floodlight-modules/src/main/java/org/openkilda/floodlight/service/kafka/KafkaProducerService.java index 6530554ebc..55711f1324 100644 --- a/src-java/floodlight-service/floodlight-modules/src/main/java/org/openkilda/floodlight/service/kafka/KafkaProducerService.java +++ b/src-java/floodlight-service/floodlight-modules/src/main/java/org/openkilda/floodlight/service/kafka/KafkaProducerService.java @@ -211,8 +211,8 @@ public void onCompletion(RecordMetadata metadata, Exception exception) { } service.failedSendMessageCounter++; logger.error( - "Fail to send message(correlationId=\"{}\") in kafka topic={}: Message json: {}. {}.", - correlationId, topic, messageJson, exception); + "Fail to send message(correlationId=\"{}\") in kafka topic={}. Message json symbol length: {}.", + correlationId, topic, messageJson.length(), exception); } } }