https://community.cloudera.com/t5/Archives-of-Support-Questions/Kafka-MirrorMaker-error/m-p/203602#M62607 <P>@<A href="https://community.hortonworks.com/users/14047/karanalang.html">Karan Alang</A> If you are using the new Kafka Consumer, try <EM>bootstrap.servers </EM>and see if that helps. </P><P>Check <A href="https://community.hortonworks.com/articles/24599/kafka-mirrormaker.html" target="_blank">https://community.hortonworks.com/articles/24599/kafka-mirrormaker.html</A> for more details. </P> Fri, 09 Jun 2017 02:00:18 GMT Schandhok 2017-06-09T02:00:18Z https://community.cloudera.com/t5/Archives-of-Support-Questions/Kafka-MirrorMaker-error/m-p/203601#M62606 <DIV> <DIV> <DIV> <DIV> <DIV>Hi All,I'm trying to transfer data between kafka clusters using Kafka MirrorMaker &amp; running into issues.I've created a consumer.config &amp; producer.config files &amp; using the command shown below. &lt;/n&gt; The error indicates - equirement failed: Missing required property 'zookeeper.connect' ------------------------------CommandLine error ----------------------------- <DIV>$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.&lt;init&gt;(ZkUtils.scala:902) at kafka.consumer.ConsumerConfig.&lt;init&gt;(ConsumerConfig.scala:101) at kafka.consumer.ConsumerConfig.&lt;init&gt;(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) <DIV> I tried adding the option (-zookeeper.connect = localhost:21810), it gives error -&gt; zookeeper.connect is not a recognized option ----------------------------- CommandLine Error ------------------------- [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 ? </DIV></DIV></DIV></DIV></DIV></DIV></DIV> Fri, 09 Jun 2017 01:54:19 GMT https://community.cloudera.com/t5/Archives-of-Support-Questions/Kafka-MirrorMaker-error/m-p/203601#M62606 karan_alang1 2017-06-09T01:54:19Z https://community.cloudera.com/t5/Archives-of-Support-Questions/Kafka-MirrorMaker-error/m-p/203602#M62607 <P>@<A href="https://community.hortonworks.com/users/14047/karanalang.html">Karan Alang</A> If you are using the new Kafka Consumer, try <EM>bootstrap.servers </EM>and see if that helps. </P><P>Check <A href="https://community.hortonworks.com/articles/24599/kafka-mirrormaker.html" target="_blank">https://community.hortonworks.com/articles/24599/kafka-mirrormaker.html</A> for more details. </P> Fri, 09 Jun 2017 02:00:18 GMT https://community.cloudera.com/t5/Archives-of-Support-Questions/Kafka-MirrorMaker-error/m-p/203602#M62607 Schandhok 2017-06-09T02:00:18Z https://community.cloudera.com/t5/Archives-of-Support-Questions/Kafka-MirrorMaker-error/m-p/203603#M62608 <P><A rel="user" href="https://community.cloudera.com/users/13875/schandhok.html" nodeid="13875">@schandhok</A> - thnx, that fixed the issue.</P> Fri, 09 Jun 2017 05:22:17 GMT https://community.cloudera.com/t5/Archives-of-Support-Questions/Kafka-MirrorMaker-error/m-p/203603#M62608 karan_alang1 2017-06-09T05:22:17Z