kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From nehanarkh...@apache.org
Subject git commit: KAFKA-811 Fix clientId in migration tool; reviewed by Neha Narkhede
Date Mon, 18 Mar 2013 21:34:29 GMT
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 <sghike@linkedin.com>
Authored: Mon Mar 18 14:34:14 2013 -0700
Committer: Neha Narkhede <neha.narkhede@gmail.com>
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);


Mime
View raw message