Permalink
Browse files

kafka-811; (Delta) Fix clientId in migration tool; patched by Swapnil…

… Ghike; reviewed by Jun Rao
  • Loading branch information...
1 parent a737986 commit 7b14ebae3382427b44a928d0b186001735c15efb Swapnil Ghike committed with junrao Mar 20, 2013
Showing with 2 additions and 1 deletion.
  1. +2 −1 core/src/main/scala/kafka/tools/KafkaMigrationTool.java
@@ -252,9 +252,10 @@ public void run() {
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);

0 comments on commit 7b14eba

Please sign in to comment.