You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by ju...@apache.org on 2013/04/18 06:54:18 UTC
[24/27] git commit: kafka-811; (Delta) Fix clientId in migration tool;
patched by Swapnil Ghike; reviewed by Jun Rao
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 <sg...@linkedin.com>
Authored: Wed Mar 20 09:44:36 2013 -0700
Committer: Jun Rao <ju...@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);