kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ij...@apache.org
Subject kafka git commit: MINOR: Fix LogContext message format in KafkaProducer
Date Thu, 14 Sep 2017 10:18:19 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk 3b5d88feb -> a0ad9f156


MINOR: Fix LogContext message format in KafkaProducer

Author: Vahid Hashemian <vahidhashemian@us.ibm.com>

Reviewers: Manikumar Reddy <manikumar.reddy@gmail.com>, Ismael Juma <ismael@juma.me.uk>

Closes #3854 from vahidhashemian/minor/fix_log_context_message_format


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

Branch: refs/heads/trunk
Commit: a0ad9f156a122e3e3a073cba0e2b0c39c93c7db5
Parents: 3b5d88f
Author: Vahid Hashemian <vahidhashemian@us.ibm.com>
Authored: Thu Sep 14 11:18:07 2017 +0100
Committer: Ismael Juma <ismael@juma.me.uk>
Committed: Thu Sep 14 11:18:07 2017 +0100

----------------------------------------------------------------------
 .../main/java/org/apache/kafka/clients/producer/KafkaProducer.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/a0ad9f15/clients/src/main/java/org/apache/kafka/clients/producer/KafkaProducer.java
----------------------------------------------------------------------
diff --git a/clients/src/main/java/org/apache/kafka/clients/producer/KafkaProducer.java b/clients/src/main/java/org/apache/kafka/clients/producer/KafkaProducer.java
index 800e98b..816566f 100644
--- a/clients/src/main/java/org/apache/kafka/clients/producer/KafkaProducer.java
+++ b/clients/src/main/java/org/apache/kafka/clients/producer/KafkaProducer.java
@@ -316,7 +316,7 @@ public class KafkaProducer<K, V> implements Producer<K, V>
{
 
             String transactionalId = userProvidedConfigs.containsKey(ProducerConfig.TRANSACTIONAL_ID_CONFIG)
?
                     (String) userProvidedConfigs.get(ProducerConfig.TRANSACTIONAL_ID_CONFIG)
: null;
-            LogContext logContext = new LogContext(String.format("[Producer clientId=%s,
transactionalId=%s", clientId, transactionalId));
+            LogContext logContext = new LogContext(String.format("[Producer clientId=%s,
transactionalId=%s] ", clientId, transactionalId));
             log = logContext.logger(KafkaProducer.class);
             log.trace("Starting the Kafka producer");
 


Mime
View raw message