From commits-return-1962-apmail-kafka-commits-archive=kafka.apache.org@kafka.apache.org Sun Oct 12 22:50:57 2014 Return-Path: X-Original-To: apmail-kafka-commits-archive@www.apache.org Delivered-To: apmail-kafka-commits-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 6A4DE17CE3 for ; Sun, 12 Oct 2014 22:50:57 +0000 (UTC) Received: (qmail 26051 invoked by uid 500); 12 Oct 2014 22:50:57 -0000 Delivered-To: apmail-kafka-commits-archive@kafka.apache.org Received: (qmail 26029 invoked by uid 500); 12 Oct 2014 22:50:57 -0000 Mailing-List: contact commits-help@kafka.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@kafka.apache.org Delivered-To: mailing list commits@kafka.apache.org Received: (qmail 26018 invoked by uid 99); 12 Oct 2014 22:50:57 -0000 Received: from tyr.zones.apache.org (HELO tyr.zones.apache.org) (140.211.11.114) by apache.org (qpsmtpd/0.29) with ESMTP; Sun, 12 Oct 2014 22:50:57 +0000 Received: by tyr.zones.apache.org (Postfix, from userid 65534) id DE84E9040C7; Sun, 12 Oct 2014 22:50:56 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: nehanarkhede@apache.org To: commits@kafka.apache.org Message-Id: <3226cd7ec06d4123a9390435cbb09a32@git.apache.org> X-Mailer: ASF-Git Admin Mailer Subject: git commit: KAFKA-1692 Include client ID in new producer IO thread name; reviewed by Neha Narkhede Date: Sun, 12 Oct 2014 22:50:56 +0000 (UTC) Repository: kafka Updated Branches: refs/heads/trunk 1733c0bfb -> 7062ed7db 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/7062ed7d Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/7062ed7d Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/7062ed7d Branch: refs/heads/trunk Commit: 7062ed7db36f913328a9124797c47f70e3461025 Parents: 1733c0b Author: Ewen Cheslack-Postava Authored: Sun Oct 12 15:50:31 2014 -0700 Committer: Neha Narkhede Committed: Sun Oct 12 15:50:48 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/7062ed7d/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");