diff --git a/core/src/main/scala/kafka/tools/MirrorMaker.scala b/core/src/main/scala/kafka/tools/MirrorMaker.scala
index 52763df..e75c4f8 100644
--- a/core/src/main/scala/kafka/tools/MirrorMaker.scala
+++ b/core/src/main/scala/kafka/tools/MirrorMaker.scala
@@ -117,7 +117,9 @@ object MirrorMaker extends Logging {
     val producerProps = Utils.loadProps(options.valueOf(producerConfigOpt))
 
     // create producer threads
-    val producers = (1 to numProducers).map(_ => {
+    val clientId = producerProps.getProperty("client.id", "")
+    val producers = (1 to numProducers).map(i => {
+      producerProps.setProperty("client.id", clientId + "-" + i)
       if (useNewProducer)
         new NewShinyProducer(producerProps)
       else