root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 2 Packages Projects Releases Wiki Activity

KAFKA-17109: Reduce log message load for failed locking (#16705) 

Reducing log messaging by removing stacktrace.

Reviewer: Bruno Cadonna <cadonna@apache.org>
This commit is contained in:
Danica Fine 2024-11-13 03:32:40 -08:00 committed by GitHub
parent 6bc7be70d7
commit 9682e63c11
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskManager.java
View File

@ -1076,7 +1076,8 @@ public class TaskManager {
} catch (final LockException lockException) { } catch (final LockException lockException) {
// The state directory may still be locked by another thread, when the rebalance just happened. // The state directory may still be locked by another thread, when the rebalance just happened.
// Retry in the next iteration. // 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)); tasks.addPendingTasksToInit(Collections.singleton(task));
updateOrCreateBackoffRecord(task.id(), nowMs); updateOrCreateBackoffRecord(task.id(), nowMs);
} }