You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by ju...@apache.org on 2014/05/17 00:31:56 UTC
git commit: kafka-1453 (2nd follow-up);
Add a channel queue jmx in Mirror Maker; patched by Guozhang Wang;
reviewed by Jun Rao
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 <gu...@linkedin.com>
Authored: Fri May 16 15:31:53 2014 -0700
Committer: Jun Rao <ju...@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