kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jun...@apache.org
Subject git commit: kafka-1453 (2nd follow-up); Add a channel queue jmx in Mirror Maker; patched by Guozhang Wang; reviewed by Jun Rao
Date Fri, 16 May 2014 22:31:56 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk 345c52ee3 -> bf7fb6321


kafka-1453 (2nd follow-up); Add a channel queue jmx in Mirror Maker;  patched by Guozhang
Wang; 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/bf7fb632
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/bf7fb632
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/bf7fb632

Branch: refs/heads/trunk
Commit: bf7fb63218640873781720a494d1114fbe628795
Parents: 345c52e
Author: Guozhang Wang <guwang@linkedin.com>
Authored: Fri May 16 15:31:53 2014 -0700
Committer: Jun Rao <junrao@gmail.com>
Committed: Fri May 16 15:31:53 2014 -0700

----------------------------------------------------------------------
 core/src/main/scala/kafka/tools/MirrorMaker.scala | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/bf7fb632/core/src/main/scala/kafka/tools/MirrorMaker.scala
----------------------------------------------------------------------
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


Mime
View raw message