Repository: kafka Updated Branches: refs/heads/trunk 3b5d88feb -> a0ad9f156
MINOR: Fix LogContext message format in KafkaProducer Author: Vahid Hashemian <vahidhashem...@us.ibm.com> Reviewers: Manikumar Reddy <manikumar.re...@gmail.com>, Ismael Juma <ism...@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 <vahidhashem...@us.ibm.com> Authored: Thu Sep 14 11:18:07 2017 +0100 Committer: Ismael Juma <ism...@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");
