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 1ECC5E6C7 for ; Mon, 18 Mar 2013 21:34:30 +0000 (UTC) Received: (qmail 91966 invoked by uid 500); 18 Mar 2013 21:34:30 -0000 Delivered-To: apmail-kafka-commits-archive@kafka.apache.org Received: (qmail 91921 invoked by uid 500); 18 Mar 2013 21:34:29 -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 91914 invoked by uid 99); 18 Mar 2013 21:34:29 -0000 Received: from tyr.zones.apache.org (HELO tyr.zones.apache.org) (140.211.11.114) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 18 Mar 2013 21:34:29 +0000 Received: by tyr.zones.apache.org (Postfix, from userid 65534) id 418673917B; Mon, 18 Mar 2013 21:34:29 +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 X-Mailer: ASF-Git Admin Mailer Subject: git commit: KAFKA-811 Fix clientId in migration tool; reviewed by Neha Narkhede Message-Id: <20130318213429.418673917B@tyr.zones.apache.org> Date: Mon, 18 Mar 2013 21:34:29 +0000 (UTC) Updated Branches: refs/heads/0.8 7fd9268f7 -> d40d255bc KAFKA-811 Fix clientId in migration tool; 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/d40d255b Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/d40d255b Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/d40d255b Branch: refs/heads/0.8 Commit: d40d255bc86a8b82dddd79c71f4a0309af6731e0 Parents: 7fd9268 Author: Swapnil Ghike Authored: Mon Mar 18 14:34:14 2013 -0700 Committer: Neha Narkhede Committed: Mon Mar 18 14:34:22 2013 -0700 ---------------------------------------------------------------------- .../main/scala/kafka/tools/KafkaMigrationTool.java | 3 ++- 1 files changed, 2 insertions(+), 1 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kafka/blob/d40d255b/core/src/main/scala/kafka/tools/KafkaMigrationTool.java ---------------------------------------------------------------------- diff --git a/core/src/main/scala/kafka/tools/KafkaMigrationTool.java b/core/src/main/scala/kafka/tools/KafkaMigrationTool.java index 95fbe46..ddf0e0b 100644 --- a/core/src/main/scala/kafka/tools/KafkaMigrationTool.java +++ b/core/src/main/scala/kafka/tools/KafkaMigrationTool.java @@ -251,9 +251,10 @@ public class KafkaMigrationTool { thread.start(); migrationThreads.add(thread); } + // start producer threads for (int i = 0; i < numProducers; i++) { - kafkaProducerProperties_08.put("client.id", String.valueOf(i) + "-" + i); + kafkaProducerProperties_08.put("client.id", kafkaProducerProperties_08.getProperty("client.id") + "-" + i); ProducerConfig producerConfig_08 = new ProducerConfig(kafkaProducerProperties_08); Producer producer = new Producer(producerConfig_08); ProducerThread producerThread = new ProducerThread(producerDataChannel, producer, i);