This is an automated email from the ASF dual-hosted git repository. cadonna pushed a commit to branch pull/16705/head in repository https://gitbox.apache.org/repos/asf/kafka.git
commit c5c5e7a24237682c5380b3cdb4bd9380198378ac Author: Bruno Cadonna <[email protected]> AuthorDate: Wed Nov 13 10:44:55 2024 +0100 Change debug to info --- .../org/apache/kafka/streams/processor/internals/TaskManager.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) 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 88aebf25b75..bdaf22b543a 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 @@ -1011,8 +1011,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.debug("Encountered lock exception. Reattempting locking the state in the next iteration. Error message was: {}", - lockException.getMessage()); + log.info("Encountered lock exception. Reattempting locking the state in the next iteration. Error message was: {}", + lockException.getMessage()); tasks.addPendingTasksToInit(Collections.singleton(task)); } }
