kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From nehanarkh...@apache.org
Subject git commit: KAFKA-1692 Include client ID in new producer IO thread name; reviewed by Neha Narkhede
Date Sun, 12 Oct 2014 23:00:33 GMT
Repository: kafka
Updated Branches:
  refs/heads/0.8.2 ca0a95665 -> fcfeba73b


KAFKA-1692 Include client ID in new producer IO thread name; reviewed by Neha Narkhede


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

Branch: refs/heads/0.8.2
Commit: fcfeba73bd8053ec41a61448315f2217df6459de
Parents: ca0a956
Author: Ewen Cheslack-Postava <me@ewencp.org>
Authored: Sun Oct 12 16:00:19 2014 -0700
Committer: Neha Narkhede <neha.narkhede@gmail.com>
Committed: Sun Oct 12 16:00:25 2014 -0700

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


http://git-wip-us.apache.org/repos/asf/kafka/blob/fcfeba73/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 f58b850..32f444e 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
@@ -139,7 +139,8 @@ public class KafkaProducer implements Producer {
                                  config.getInt(ProducerConfig.TIMEOUT_CONFIG),
                                  this.metrics,
                                  new SystemTime());
-        this.ioThread = new KafkaThread("kafka-producer-network-thread", this.sender, true);
+        String ioThreadName = "kafka-producer-network-thread" + (clientId.length() > 0
? " | " + clientId : "");
+        this.ioThread = new KafkaThread(ioThreadName, this.sender, true);
         this.ioThread.start();
 
         this.errors = this.metrics.sensor("errors");


Mime
View raw message