The producer configuration should list the kafka brokers, not the zookeeper quorum. See here: http://kafka.apache.org/documentation.html#producerconfigs
(and send my regards to Alex Gorbachev ;) Gwen On Fri, Oct 31, 2014 at 8:05 PM, Tomas Nunez <nu...@pythian.com> wrote: > Hi > > I'm trying to upgrade a 0.7 kafka cluster, but I'm getting an error: > > I created the file migrationToolConsumer.properties with just theinfo to > connect to the old cluster: > _____ > zookeeper.connect=zookeeper01:2181,zookeeper02:2181,zookeeper03:2181 > group.id=migration.prod > ______ > > > Then the producer file > _______ > > zookeeper.connect=zookeeper01_new:2181,zookeeper02_new:2181,zookeeper03_new:2181 > group.id=migration.prod > _______ > > And then I called the migrationtool, and get this error > > ______________ > $ kafka/bin/kafka-run-class.sh kafka.tools.KafkaMigrationTool > --kafka.07.jar migration-tool/kafka-0.7.2.jar --zkclient.01.jar > migration-tool/zkclient-0.1.jar --num.producers 4 > --consumer.config=kafka/config/migrationToolConsumer.properties > -producer.config=kafka/config/migrationToolProducer.properties > --whitelist=.* > Kafka migration tool failed due to: > java.lang.reflect.InvocationTargetException > at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native > Method) > at > > sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:57) > at > > sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45) > at java.lang.reflect.Constructor.newInstance(Constructor.java:526) > at kafka.tools.KafkaMigrationTool.main(KafkaMigrationTool.java:200) > Caused by: java.lang.NoClassDefFoundError: scala/Tuple2$mcLL$sp > at kafka.utils.ZKConfig.<init>(ZkUtils.scala:302) > at kafka.consumer.ConsumerConfig.<init>(ConsumerConfig.scala:44) > ... 5 more > Caused by: java.lang.ClassNotFoundException: scala.Tuple2$mcLL$sp > at java.lang.ClassLoader.findClass(ClassLoader.java:531) > at > > kafka.tools.KafkaMigrationTool$ParentLastURLClassLoader$FindClassClassLoader.findClass(KafkaMigrationTool.java:440) > at java.lang.ClassLoader.loadClass(ClassLoader.java:425) > at java.lang.ClassLoader.loadClass(ClassLoader.java:358) > at > > kafka.tools.KafkaMigrationTool$ParentLastURLClassLoader$ChildURLClassLoader.findClass(KafkaMigrationTool.java:463) > at java.lang.ClassLoader.loadClass(ClassLoader.java:425) > at java.lang.ClassLoader.loadClass(ClassLoader.java:358) > ... 7 more > > [2014-11-01 02:51:35,124] ERROR Kafka migration tool failed: > (kafka.tools.KafkaMigrationTool) > java.lang.reflect.InvocationTargetException > at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native > Method) > at > > sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:57) > at > > sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45) > at java.lang.reflect.Constructor.newInstance(Constructor.java:526) > at kafka.tools.KafkaMigrationTool.main(KafkaMigrationTool.java:200) > Caused by: java.lang.NoClassDefFoundError: scala/Tuple2$mcLL$sp > at kafka.utils.ZKConfig.<init>(ZkUtils.scala:302) > at kafka.consumer.ConsumerConfig.<init>(ConsumerConfig.scala:44) > ... 5 more > Caused by: java.lang.ClassNotFoundException: scala.Tuple2$mcLL$sp > at java.lang.ClassLoader.findClass(ClassLoader.java:531) > at > > kafka.tools.KafkaMigrationTool$ParentLastURLClassLoader$FindClassClassLoader.findClass(KafkaMigrationTool.java:440) > at java.lang.ClassLoader.loadClass(ClassLoader.java:425) > at java.lang.ClassLoader.loadClass(ClassLoader.java:358) > at > > kafka.tools.KafkaMigrationTool$ParentLastURLClassLoader$ChildURLClassLoader.findClass(KafkaMigrationTool.java:463) > at java.lang.ClassLoader.loadClass(ClassLoader.java:425) > at java.lang.ClassLoader.loadClass(ClassLoader.java:358) > ... 7 more > __________ > > > The files kafka-0.7.2.jar and zkclient-0.1.jar are the exact same ones > that are being used in the old 0.7 cluster. > > I also tried downloading and building a new 0.7.2 jar file with scala, but > it had the same error, too. > > What can I be doing wrong? Is there any way to get more output to see where > is the error? > > Thanks in advance, > > -- > Tomàs Núñez > Enterprise Infrastructure Consultant > The Pythian Group - Love your data! > > Office (international): +1 613 565 8696 x1501 > > -- > > > -- > > > >
