You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by ne...@apache.org on 2013/03/18 22:34:29 UTC
git commit: KAFKA-811 Fix clientId in migration tool;
reviewed by Neha Narkhede
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 <sg...@linkedin.com>
Authored: Mon Mar 18 14:34:14 2013 -0700
Committer: Neha Narkhede <ne...@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);