From ee4759fcb65e76be76285ab2535f4fed15eec455 Mon Sep 17 00:00:00 2001 From: Jorge Esteban Quilcate Otoya Date: Wed, 8 May 2024 15:27:03 +0300 Subject: [PATCH] KAFKA-16685: Add parent exception to RLMTask warning logs (#15880) KAFKA-16685: Add parent exception to RLMTask warning logs Reviewers: Josep Prat --- core/src/main/java/kafka/log/remote/RemoteLogManager.java | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/core/src/main/java/kafka/log/remote/RemoteLogManager.java b/core/src/main/java/kafka/log/remote/RemoteLogManager.java index de007096b511..26628ed9dfa7 100644 --- a/core/src/main/java/kafka/log/remote/RemoteLogManager.java +++ b/core/src/main/java/kafka/log/remote/RemoteLogManager.java @@ -831,14 +831,13 @@ public void run() { } } catch (InterruptedException ex) { if (!isCancelled()) { - logger.warn("Current thread for topic-partition-id {} is interrupted. Reason: {}", topicIdPartition, ex.getMessage()); + logger.warn("Current thread for topic-partition-id {} is interrupted", topicIdPartition, ex); } } catch (RetriableException ex) { logger.debug("Encountered a retryable error while executing current task for topic-partition {}", topicIdPartition, ex); } catch (Exception ex) { if (!isCancelled()) { - logger.warn("Current task for topic-partition {} received error but it will be scheduled. " + - "Reason: {}", topicIdPartition, ex.getMessage()); + logger.warn("Current task for topic-partition {} received error but it will be scheduled", topicIdPartition, ex); } } }