kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jun...@apache.org
Subject [24/27] git commit: kafka-811; (Delta) Fix clientId in migration tool; patched by Swapnil Ghike; reviewed by Jun Rao
Date Thu, 18 Apr 2013 04:54:18 GMT
kafka-811; (Delta) Fix clientId in migration tool; patched by Swapnil Ghike; reviewed by Jun
Rao


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

Branch: refs/heads/trunk
Commit: 7b14ebae3382427b44a928d0b186001735c15efb
Parents: a737986
Author: Swapnil Ghike <sghike@linkedin.com>
Authored: Wed Mar 20 09:44:36 2013 -0700
Committer: Jun Rao <junrao@gmail.com>
Committed: Wed Mar 20 09:44:36 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/7b14ebae/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 ddf0e0b..eb63d75 100644
--- a/core/src/main/scala/kafka/tools/KafkaMigrationTool.java
+++ b/core/src/main/scala/kafka/tools/KafkaMigrationTool.java
@@ -252,9 +252,10 @@ public class KafkaMigrationTool {
         migrationThreads.add(thread);
       }
 
+      String clientId = kafkaProducerProperties_08.getProperty("client.id");
       // start producer threads
       for (int i = 0; i < numProducers; i++) {
-        kafkaProducerProperties_08.put("client.id", kafkaProducerProperties_08.getProperty("client.id")
+ "-" + i);
+        kafkaProducerProperties_08.put("client.id", clientId + "-" + 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