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:23 GMT
Repository: kafka
Updated Branches:
  refs/heads/0.11.0 27a8b4fe5 -> f2673eb37


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

(cherry picked from commit 0b107e5f752f4f7d1d6dc97891cb9569c3db5b3d)
Signed-off-by: Jason Gustafson <jason@confluent.io>


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

Branch: refs/heads/0.11.0
Commit: f2673eb37818f5e74fdbec90b5277822ce247bd3
Parents: 27a8b4f
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:21 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/f2673eb3/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