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 <[email protected]> Authored: Sun Oct 12 16:00:19 2014 -0700 Committer: Neha Narkhede <[email protected]> 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");
