Repository: kafka
Updated Branches:
  refs/heads/trunk a318b1512 -> 0b107e5f7


HOTFIX: Reinstate the placeholder for logPrefix in TransactionManager

Author: Apurva Mehta <[email protected]>

Reviewers: Jason Gustafson <[email protected]>

Closes #3216 from apurvam/HOTFIX-logging-bug-in-transaction-manager


Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/0b107e5f
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/0b107e5f
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/0b107e5f

Branch: refs/heads/trunk
Commit: 0b107e5f752f4f7d1d6dc97891cb9569c3db5b3d
Parents: a318b15
Author: Apurva Mehta <[email protected]>
Authored: Fri Jun 2 15:29:09 2017 -0700
Committer: Jason Gustafson <[email protected]>
Committed: Fri Jun 2 15:29:09 2017 -0700

----------------------------------------------------------------------
 .../kafka/clients/producer/internals/TransactionManager.java       | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/0b107e5f/clients/src/main/java/org/apache/kafka/clients/producer/internals/TransactionManager.java
----------------------------------------------------------------------
diff --git 
a/clients/src/main/java/org/apache/kafka/clients/producer/internals/TransactionManager.java
 
b/clients/src/main/java/org/apache/kafka/clients/producer/internals/TransactionManager.java
index aade83e..dad6b5d 100644
--- 
a/clients/src/main/java/org/apache/kafka/clients/producer/internals/TransactionManager.java
+++ 
b/clients/src/main/java/org/apache/kafka/clients/producer/internals/TransactionManager.java
@@ -473,7 +473,7 @@ public class TransactionManager {
             log.error("{}Transition from state {} to error state {}", 
logPrefix, currentState,
                     target, lastError);
         else
-            log.debug("Transition from state {} to {}", logPrefix, 
currentState, target);
+            log.debug("{}Transition from state {} to {}", logPrefix, 
currentState, target);
 
         currentState = target;
     }

Reply via email to