You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by Parin Jogani <pa...@gmail.com> on 2014/08/24 04:16:26 UTC

kafka unit test in Java, TestUtils choosePort sends NoSuchMethodError

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 <pa...@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

Re: kafka unit test in Java, TestUtils choosePort sends NoSuchMethodError

Posted by Gwen Shapira <gs...@cloudera.com>.
So it looks like you are depending on a Kafka artifact which was build
with Scala 2.9.2, and importing Scala 2.10.1

Scala is not binary compatible between versions, so you need either
both 2.10 or both 2.9.

Gwen

On Fri, Aug 29, 2014 at 11:41 AM, Parin Jogani <pa...@gmail.com> wrote:
> so I always had this in my project:
>>
>>  <dependency>
>>             <groupId>org.scala-lang</groupId>
>>             <artifactId>scala-library</artifactId>
>>             <version>2.10.1</version>
>>  </dependency>
>
>
>
>
> -Parin
>
>
>
> On Thu, Aug 28, 2014 at 12:00 AM, Jun Rao <ju...@gmail.com> wrote:
>
>> Kafka is written in scala. So to run Kafka, you need a scala jar.
>>
>> Thanks,
>>
>> Jun
>>
>>
>> On Wed, Aug 27, 2014 at 4:05 PM, Parin Jogani <pa...@gmail.com>
>> wrote:
>>
>> > As far as I understand it shouldnt have such a dependency. JVM should be
>> > able to compile this. I am using JDK1.6. Also this is a unit test.
>> > Correct me if I am wrong. I have not downloaded any scala before even
>> till
>> > this far.
>> >
>> >
>> > -Parin
>> >
>> >
>> > On Tue, Aug 26, 2014 at 10:12 PM, Jun Rao <ju...@gmail.com> wrote:
>> >
>> > > 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 <pa...@gmail.com>
>> > > wrote:
>> > >
>> > > > Can anyone help?
>> > > >
>> > > >
>> > > >
>> > > >
>> > > > On Sat, Aug 23, 2014 at 9:38 PM, Parin Jogani <
>> parin.jogani@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 <wangguoz@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.jogani@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.jogani@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
>> > > >
>> > >
>> >
>> >
>> >
>> > --
>> > Regards,
>> > Parin
>> >
>>
>
>
>
> --
> Regards,
> Parin

Re: kafka unit test in Java, TestUtils choosePort sends NoSuchMethodError

Posted by Parin Jogani <pa...@gmail.com>.
so I always had this in my project:
>
>  <dependency>
>             <groupId>org.scala-lang</groupId>
>             <artifactId>scala-library</artifactId>
>             <version>2.10.1</version>
>  </dependency>




-Parin



On Thu, Aug 28, 2014 at 12:00 AM, Jun Rao <ju...@gmail.com> wrote:

> Kafka is written in scala. So to run Kafka, you need a scala jar.
>
> Thanks,
>
> Jun
>
>
> On Wed, Aug 27, 2014 at 4:05 PM, Parin Jogani <pa...@gmail.com>
> wrote:
>
> > As far as I understand it shouldnt have such a dependency. JVM should be
> > able to compile this. I am using JDK1.6. Also this is a unit test.
> > Correct me if I am wrong. I have not downloaded any scala before even
> till
> > this far.
> >
> >
> > -Parin
> >
> >
> > On Tue, Aug 26, 2014 at 10:12 PM, Jun Rao <ju...@gmail.com> wrote:
> >
> > > 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 <pa...@gmail.com>
> > > wrote:
> > >
> > > > Can anyone help?
> > > >
> > > >
> > > >
> > > >
> > > > On Sat, Aug 23, 2014 at 9:38 PM, Parin Jogani <
> parin.jogani@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 <wangguoz@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.jogani@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.jogani@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
> > > >
> > >
> >
> >
> >
> > --
> > Regards,
> > Parin
> >
>



-- 
Regards,
Parin

Re: kafka unit test in Java, TestUtils choosePort sends NoSuchMethodError

Posted by Jun Rao <ju...@gmail.com>.
Kafka is written in scala. So to run Kafka, you need a scala jar.

Thanks,

Jun


On Wed, Aug 27, 2014 at 4:05 PM, Parin Jogani <pa...@gmail.com>
wrote:

> As far as I understand it shouldnt have such a dependency. JVM should be
> able to compile this. I am using JDK1.6. Also this is a unit test.
> Correct me if I am wrong. I have not downloaded any scala before even till
> this far.
>
>
> -Parin
>
>
> On Tue, Aug 26, 2014 at 10:12 PM, Jun Rao <ju...@gmail.com> wrote:
>
> > 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 <pa...@gmail.com>
> > wrote:
> >
> > > Can anyone help?
> > >
> > >
> > >
> > >
> > > On Sat, Aug 23, 2014 at 9:38 PM, Parin Jogani <pa...@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 <wa...@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.jogani@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.jogani@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
> > >
> >
>
>
>
> --
> Regards,
> Parin
>

Re: kafka unit test in Java, TestUtils choosePort sends NoSuchMethodError

Posted by Parin Jogani <pa...@gmail.com>.
As far as I understand it shouldnt have such a dependency. JVM should be
able to compile this. I am using JDK1.6. Also this is a unit test.
Correct me if I am wrong. I have not downloaded any scala before even till
this far.


-Parin


On Tue, Aug 26, 2014 at 10:12 PM, Jun Rao <ju...@gmail.com> wrote:

> 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 <pa...@gmail.com>
> wrote:
>
> > Can anyone help?
> >
> >
> >
> >
> > On Sat, Aug 23, 2014 at 9:38 PM, Parin Jogani <pa...@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 <wa...@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.jogani@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.jogani@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
> >
>



-- 
Regards,
Parin

Re: kafka unit test in Java, TestUtils choosePort sends NoSuchMethodError

Posted by Jun Rao <ju...@gmail.com>.
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 <pa...@gmail.com>
wrote:

> Can anyone help?
>
>
>
>
> On Sat, Aug 23, 2014 at 9:38 PM, Parin Jogani <pa...@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 <wa...@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 <pa...@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.jogani@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
>

Re: kafka unit test in Java, TestUtils choosePort sends NoSuchMethodError

Posted by Parin Jogani <pa...@gmail.com>.
Can anyone help?




On Sat, Aug 23, 2014 at 9:38 PM, Parin Jogani <pa...@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 <wa...@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 <pa...@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 <pa...@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

Re: kafka unit test in Java, TestUtils choosePort sends NoSuchMethodError

Posted by Parin Jogani <pa...@gmail.com>.
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 <wa...@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 <pa...@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 <pa...@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

Re: kafka unit test in Java, TestUtils choosePort sends NoSuchMethodError

Posted by Guozhang Wang <wa...@gmail.com>.
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 <pa...@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 <pa...@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