kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From j...@apache.org
Subject kafka git commit: HOTFIX: Reinstate the placeholder for logPrefix in TransactionManager
Date Fri, 02 Jun 2017 22:29:15 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk a318b1512 -> 0b107e5f7


HOTFIX: Reinstate the placeholder for logPrefix in TransactionManager

Author: Apurva Mehta <apurva@confluent.io>

Reviewers: Jason Gustafson <jason@confluent.io>

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 <apurva@confluent.io>
Authored: Fri Jun 2 15:29:09 2017 -0700
Committer: Jason Gustafson <jason@confluent.io>
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;
     }


Mime
View raw message