(kafka) branch trunk updated: KAFKA-17109: Reduce log message load for failed locking (#16705)

[cadonna]

This is an automated email from the ASF dual-hosted git repository.

cadonna pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/trunk by this push:
     new 9682e63c114 KAFKA-17109: Reduce log message load for failed locking 
(#16705)
9682e63c114 is described below

commit 9682e63c11447d7448db00fd6477fd00a9ace327
Author: Danica Fine <danica.f...@gmail.com>
AuthorDate: Wed Nov 13 03:32:40 2024 -0800

    KAFKA-17109: Reduce log message load for failed locking (#16705)
    
    Reducing log messaging by removing stacktrace.
    
    Reviewer: Bruno Cadonna <cado...@apache.org>
---
 .../java/org/apache/kafka/streams/processor/internals/TaskManager.java | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git 
a/streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java
 
b/streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java
index 8a6e27b4c99..f361d3dc320 100644
--- 
a/streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java
+++ 
b/streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java
@@ -1076,7 +1076,8 @@ public class TaskManager {
         } catch (final LockException lockException) {
             // The state directory may still be locked by another thread, when 
the rebalance just happened.
             // Retry in the next iteration.
-            log.info("Encountered lock exception. Reattempting locking the 
state in the next iteration.", lockException);
+            log.info("Encountered lock exception. Reattempting locking the 
state in the next iteration. Error message was: {}",
+                     lockException.getMessage());
             tasks.addPendingTasksToInit(Collections.singleton(task));
             updateOrCreateBackoffRecord(task.id(), nowMs);
         }