You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by ch...@apache.org on 2021/03/09 13:58:46 UTC
[kafka] branch 2.8 updated: MINOR: Add missing log argument (#10262)
This is an automated email from the ASF dual-hosted git repository.
chia7712 pushed a commit to branch 2.8
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/2.8 by this push:
new 45b045e MINOR: Add missing log argument (#10262)
45b045e is described below
commit 45b045e188bf38713bc806a3af52ac2c56f1e0e9
Author: Tom Bentley <to...@users.noreply.github.com>
AuthorDate: Tue Mar 9 04:46:43 2021 +0000
MINOR: Add missing log argument (#10262)
Reviewers: Chia-Ping Tsai <ch...@gmail.com>
---
metadata/src/main/java/org/apache/kafka/metalog/LocalLogManager.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/metadata/src/main/java/org/apache/kafka/metalog/LocalLogManager.java b/metadata/src/main/java/org/apache/kafka/metalog/LocalLogManager.java
index 99ae3a7..819de56 100644
--- a/metadata/src/main/java/org/apache/kafka/metalog/LocalLogManager.java
+++ b/metadata/src/main/java/org/apache/kafka/metalog/LocalLogManager.java
@@ -139,7 +139,7 @@ public final class LocalLogManager implements MetaLogManager, AutoCloseable {
}
if (nodeId != leader.nodeId()) {
log.trace("tryAppend(nodeId={}, epoch={}): the given node id does not " +
- "match the current leader id of {}.", nodeId, leader.nodeId());
+ "match the current leader id of {}.", nodeId, epoch, leader.nodeId());
return Long.MAX_VALUE;
}
log.trace("tryAppend(nodeId={}): appending {}.", nodeId, batch);