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 <[email protected]> Authored: Fri May 16 15:31:53 2014 -0700 Committer: Jun Rao <[email protected]> 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
