Thanks, that fixed the issue !
On Thu, Jun 8, 2017 at 11:58 AM, Mostafa Zarifyar <mzarif...@elementum.com> wrote: > maybe this will help. > > https://community.hortonworks.com/articles/24599/kafka-mirrormaker.html > > -M > > On Thu, Jun 8, 2017 at 11:42 AM, karan alang <karan.al...@gmail.com> > wrote: > > > Hi All, > > > > I'm trying to transfer data between kafka clusters using Kafka > MirrorMaker > > & running into issues. > > > > I've created a consumer.config & producer.config files & using the > command > > shown below. > > The error indicates - equirement failed: Missing required property > > 'zookeeper.connect' > > > > ------------------------------ > > $KAFKA10_HOME/bin/kafka-run-class.sh kafka.tools.MirrorMaker > > --consumer.config $KAFKA10_HOME/config/mmConsumer.config --num.streams 2 > > --producer.config $KAFKA10_HOME/config/mmProducer.config > > --whitelist="mmtopic" > > [2017-06-08 11:32:55,962] ERROR Exception when starting mirror maker. > > (kafka.tools.MirrorMaker$) > > java.lang.IllegalArgumentException: requirement failed: Missing required > > property 'zookeeper.connect' > > at scala.Predef$.require(Predef.scala:224) > > at > > kafka.utils.VerifiableProperties.getString(VerifiableProperties.scala: > 177) > > at kafka.utils.ZKConfig.<init>(ZkUtils.scala:902) > > at kafka.consumer.ConsumerConfig.<init>(ConsumerConfig.scala:101) > > at kafka.consumer.ConsumerConfig.<init>(ConsumerConfig.scala:105) > > at kafka.tools.MirrorMaker$$anonfun$3.apply(MirrorMaker.scala:306) > > at kafka.tools.MirrorMaker$$anonfun$3.apply(MirrorMaker.scala:304) > > at > > scala.collection.TraversableLike$$anonfun$map$ > > 1.apply(TraversableLike.scala:234) > > at > > scala.collection.TraversableLike$$anonfun$map$ > > 1.apply(TraversableLike.scala:234) > > at scala.collection.immutable.Range.foreach(Range.scala:160) > > at scala.collection.TraversableLike$class.map( > > TraversableLike.scala:234) > > at scala.collection.AbstractTraversable.map(Traversable.scala:104) > > at kafka.tools.MirrorMaker$.createOldConsumers( > MirrorMaker.scala:304) > > at kafka.tools.MirrorMaker$.main(MirrorMaker.scala:233) > > at kafka.tools.MirrorMaker.main(MirrorMaker.scala) > > Exception in thread "main" java.lang.NullPointerException > > at kafka.tools.MirrorMaker$.main(MirrorMaker.scala:286) > > at kafka.tools.MirrorMaker.main(MirrorMaker.scala) > > > > > > I tried adding the option (-zookeeper.connect = localhost:21810), it > gives > > error -> zookeeper.connect is not a recognized option > > > > ----------------------------- > > > > [2017-06-08 11:40:11,033] ERROR Exception when starting mirror maker. > > (kafka.tools.MirrorMaker$) > > joptsimple.UnrecognizedOptionException: zookeeper.connect is not a > > recognized option > > at > > joptsimple.OptionException.unrecognizedOption(OptionException.java:108) > > at joptsimple.OptionParser.handleLongOptionToken( > > OptionParser.java:449) > > at > > joptsimple.OptionParserState$2.handleArgument(OptionParserState.java:56) > > at joptsimple.OptionParser.parse(OptionParser.java:381) > > at kafka.tools.MirrorMaker$.main(MirrorMaker.scala:167) > > at kafka.tools.MirrorMaker.main(MirrorMaker.scala) > > Exception in thread "main" java.lang.NullPointerException > > at kafka.tools.MirrorMaker$.main(MirrorMaker.scala:286) > > at kafka.tools.MirrorMaker.main(MirrorMaker.scala) > > > > > > Any ideas on what needs to be done ? > > > > -- > > > Legal Disclaimer: The information contained in this message may be > privileged and confidential. It is intended to be read only by the > individual or entity to whom it is addressed or by their designee. If the > reader of this message is not the intended recipient, you are on notice > that any distribution of this message, in any form, is strictly prohibited. > If you have received this message in error, please immediately notify the > sender and delete or destroy any copy of this message >
