Skip to content

Commit

Permalink
KAFKA-16685: Add parent exception to RLMTask warning logs (apache#15880)
Browse files Browse the repository at this point in the history
KAFKA-16685: Add parent exception to RLMTask warning logs

Reviewers: Josep Prat <[email protected]>
  • Loading branch information
jeqo authored and biggusdonzus committed Jul 2, 2024
1 parent 89ed144 commit ee4759f
Showing 1 changed file with 2 additions and 3 deletions.
5 changes: 2 additions & 3 deletions core/src/main/java/kafka/log/remote/RemoteLogManager.java
Original file line number Diff line number Diff line change
Expand Up @@ -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);
}
}
}
Expand Down

0 comments on commit ee4759f

Please sign in to comment.