Could you make sure that you are using the scala 2.9.2 jar? Thanks,
Jun On Tue, Aug 26, 2014 at 9:28 PM, Parin Jogani <parin.jog...@gmail.com> wrote: > Can anyone help? > > > > > On Sat, Aug 23, 2014 at 9:38 PM, Parin Jogani <parin.jog...@gmail.com> > wrote: > > > Kafka: > > > >> <groupId>org.apache.kafka</groupId> > >> <artifactId>kafka_2.9.2</artifactId> > >> <version>0.8.1.1</version> > >> <scope>test</scope> > > > > > > My tests are in Java: junit, so dont know how scala would make a > > difference. > > > > Hope this helps! > > > > -Parin > > > > > > > > On Sat, Aug 23, 2014 at 7:54 PM, Guozhang Wang <wangg...@gmail.com> > wrote: > > > >> Parin, > >> > >> Which scala version are you using? And which kafka version are you > working > >> on? > >> > >> Guozhang > >> > >> > >> On Sat, Aug 23, 2014 at 7:16 PM, Parin Jogani <parin.jog...@gmail.com> > >> wrote: > >> > >> > I am trying to create unit test case for Kafka in Java with a simple > >> call > >> > > >> > Properties props =TestUtils.createBrokerConfig(1, > >> > TestUtils.choosePort(), true); > >> > > >> > It fails on > >> > > >> > > > java.lang.NoSuchMethodError: > >> > > scala.Predef$.intWrapper(I)Lscala/runtime/RichInt; > >> > > > >> > > > at kafka.utils.TestUtils$.choosePorts(TestUtils.scala:68) > >> > > > at kafka.utils.TestUtils$.choosePort(TestUtils.scala:79) > >> > > > at kafka.utils.TestUtils.choosePort(TestUtils.scala) > >> > > > at > >> > > > >> > > >> > com.ebay.jetstream.event.channel.kafka.test.KafkaTest.getKafkaConfig(KafkaTest.java:31) > >> > > > at > >> > > > >> > > >> > com.ebay.jetstream.event.channel.kafka.test.KafkaTest.runKafkaTest(KafkaTest.java:22) > >> > > > at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) > >> > > > at > >> > > > >> > > >> > sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39) > >> > > > at > >> > > > >> > > >> > sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25) > >> > > > at java.lang.reflect.Method.invoke(Method.java:597) > >> > > > at > org.junit.internal.runners.TestMethod.invoke(TestMethod.java:59) > >> > > > at > >> > > > >> > > >> > org.junit.internal.runners.MethodRoadie.runTestMethod(MethodRoadie.java:98) > >> > > > at > >> org.junit.internal.runners.MethodRoadie$2.run(MethodRoadie.java:79) > >> > > > at > >> > > > >> > > >> > org.junit.internal.runners.MethodRoadie.runBeforesThenTestThenAfters(MethodRoadie.java:87) > >> > > > at > >> > org.junit.internal.runners.MethodRoadie.runTest(MethodRoadie.java:77) > >> > > > at > org.junit.internal.runners.MethodRoadie.run(MethodRoadie.java:42) > >> > > > at > >> > > > >> > > >> > org.junit.internal.runners.JUnit4ClassRunner.invokeTestMethod(JUnit4ClassRunner.java:88) > >> > > > at > >> > > > >> > > >> > org.junit.internal.runners.JUnit4ClassRunner.runMethods(JUnit4ClassRunner.java:51) > >> > > > at > >> > > > >> > > >> > org.junit.internal.runners.JUnit4ClassRunner$1.run(JUnit4ClassRunner.java:44) > >> > > > at > >> > > > >> > > >> > org.junit.internal.runners.ClassRoadie.runUnprotected(ClassRoadie.java:27) > >> > > > at > >> > > > >> org.junit.internal.runners.ClassRoadie.runProtected(ClassRoadie.java:37) > >> > > > at > >> > > > >> > > >> > org.junit.internal.runners.JUnit4ClassRunner.run(JUnit4ClassRunner.java:42) > >> > > > at > >> > > > >> > > >> > org.eclipse.jdt.internal.junit4.runner.JUnit4TestReference.run(JUnit4TestReference.java:50) > >> > > > at > >> > > > >> > > >> > org.eclipse.jdt.internal.junit.runner.TestExecution.run(TestExecution.java:38) > >> > > > at > >> > > > >> > > >> > org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.runTests(RemoteTestRunner.java:467) > >> > > > at > >> > > > >> > > >> > org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.runTests(RemoteTestRunner.java:683) > >> > > > at > >> > > > >> > > >> > org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.run(RemoteTestRunner.java:390) > >> > > > at > >> > > > >> > > >> > org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.main(RemoteTestRunner.java:197) > >> > > > >> > > > >> > I also tried: > >> > > >> > scala.collection.Iterator<Properties> props > >> > = TestUtils.createBrokerConfigs(1, true).iterator(); > >> > Same result. > >> > > >> > This is a simple call to create kafka server, dont know what is going > >> > wrong. > >> > > >> > > >> > > >> > > >> > > >> > On Tue, Aug 19, 2014 at 10:37 PM, Parin Jogani < > parin.jog...@gmail.com> > >> > wrote: > >> > > >> > > I am trying to create unit test case for Kafka with a simple call > >> > > > >> > > Properties props =TestUtils.createBrokerConfig(1, > >> > > TestUtils.choosePort(), true); > >> > > > >> > > It fails on > >> > > > >> > >> java.lang.NoSuchMethodError: > >> > >> scala.Predef$.intWrapper(I)Lscala/runtime/RichInt; > >> > >> at kafka.utils.TestUtils$.choosePorts(TestUtils.scala:68) > >> > >> at kafka.utils.TestUtils$.choosePort(TestUtils.scala:79) > >> > >> at kafka.utils.TestUtils.choosePort(TestUtils.scala) > >> > >> at > >> > >> > >> > > >> > com.ebay.jetstream.event.channel.kafka.test.KafkaTest.getKafkaConfig(KafkaTest.java:31) > >> > >> at > >> > >> > >> > > >> > com.ebay.jetstream.event.channel.kafka.test.KafkaTest.runKafkaTest(KafkaTest.java:22) > >> > >> at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) > >> > >> at > >> > >> > >> > > >> > sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39) > >> > >> at > >> > >> > >> > > >> > sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25) > >> > >> at java.lang.reflect.Method.invoke(Method.java:597) > >> > >> at org.junit.internal.runners.TestMethod.invoke(TestMethod.java:59) > >> > >> at > >> > >> > >> > > >> > org.junit.internal.runners.MethodRoadie.runTestMethod(MethodRoadie.java:98) > >> > >> at > >> org.junit.internal.runners.MethodRoadie$2.run(MethodRoadie.java:79) > >> > >> at > >> > >> > >> > > >> > org.junit.internal.runners.MethodRoadie.runBeforesThenTestThenAfters(MethodRoadie.java:87) > >> > >> at > >> > org.junit.internal.runners.MethodRoadie.runTest(MethodRoadie.java:77) > >> > >> at > org.junit.internal.runners.MethodRoadie.run(MethodRoadie.java:42) > >> > >> at > >> > >> > >> > > >> > org.junit.internal.runners.JUnit4ClassRunner.invokeTestMethod(JUnit4ClassRunner.java:88) > >> > >> at > >> > >> > >> > > >> > org.junit.internal.runners.JUnit4ClassRunner.runMethods(JUnit4ClassRunner.java:51) > >> > >> at > >> > >> > >> > > >> > org.junit.internal.runners.JUnit4ClassRunner$1.run(JUnit4ClassRunner.java:44) > >> > >> at > >> > >> > >> > > >> > org.junit.internal.runners.ClassRoadie.runUnprotected(ClassRoadie.java:27) > >> > >> at > >> > >> > >> org.junit.internal.runners.ClassRoadie.runProtected(ClassRoadie.java:37) > >> > >> at > >> > >> > >> > > >> > org.junit.internal.runners.JUnit4ClassRunner.run(JUnit4ClassRunner.java:42) > >> > >> at > >> > >> > >> > > >> > org.eclipse.jdt.internal.junit4.runner.JUnit4TestReference.run(JUnit4TestReference.java:50) > >> > >> at > >> > >> > >> > > >> > org.eclipse.jdt.internal.junit.runner.TestExecution.run(TestExecution.java:38) > >> > >> at > >> > >> > >> > > >> > org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.runTests(RemoteTestRunner.java:467) > >> > >> at > >> > >> > >> > > >> > org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.runTests(RemoteTestRunner.java:683) > >> > >> at > >> > >> > >> > > >> > org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.run(RemoteTestRunner.java:390) > >> > >> at > >> > >> > >> > > >> > org.eclipse.jdt.internal.junit.runner.RemoteTestRunner.main(RemoteTestRunner.java:197) > >> > > > >> > > > >> > > I also tried: > >> > > > >> > > scala.collection.Iterator<Properties> propsI > >> > > = TestUtils.createBrokerConfigs(1, true).iterator(); > >> > > Same result. > >> > > > >> > > This is a simple call to create kafka server, dont know what is > going > >> > > wrong. > >> > > > >> > > > >> > > -- > >> > > Regards, > >> > > Parin > >> > > > >> > > >> > > >> > > >> > -- > >> > Regards, > >> > Parin > >> > > >> > >> > >> > >> -- > >> -- Guozhang > >> > > > > > > > > -- > > Regards, > > Parin > > > > > > -- > Regards, > Parin >
