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

chia7712 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 a1fb80f  MINOR: Add missing log argument (#10262)
a1fb80f is described below

commit a1fb80ffe2556b00869e2cd0bf79e5e9da4d9ef8
Author: Tom Bentley <[email protected]>
AuthorDate: Tue Mar 9 04:46:43 2021 +0000

    MINOR: Add missing log argument (#10262)
    
    Reviewers: Chia-Ping Tsai <[email protected]>
---
 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);

Reply via email to