Updated Branches: refs/heads/0.8 a737986e5 -> 7b14ebae3
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/0.8 Commit: 7b14ebae3382427b44a928d0b186001735c15efb Parents: a737986 Author: Swapnil Ghike <[email protected]> Authored: Wed Mar 20 09:44:36 2013 -0700 Committer: Jun Rao <[email protected]> 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);
