Skip to content

HTTPS clone URL

Subversion checkout URL

You can clone with HTTPS or Subversion.

Download ZIP
Browse files

KAFKA-811 Fix clientId in migration tool; reviewed by Neha Narkhede

  • Loading branch information...
commit d40d255bc86a8b82dddd79c71f4a0309af6731e0 1 parent 7fd9268
Swapnil Ghike authored nehanarkhede committed
Showing with 2 additions and 1 deletion.
  1. +2 −1  core/src/main/scala/kafka/tools/KafkaMigrationTool.java
View
3  core/src/main/scala/kafka/tools/KafkaMigrationTool.java
@@ -251,9 +251,10 @@ public void run() {
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);
Please sign in to comment.
Something went wrong with that request. Please try again.