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
--
--
