Re: kafka unit test in Java, TestUtils choosePort sends NoSuchMethodError
so I always had this in my project: > > > org.scala-lang > scala-library > 2.10.1 > -Parin On Thu, Aug 28, 2014 at 12:00 AM, Jun Rao 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 > 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 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 > > > wrote: > > > > > > > Can anyone help? > > > > > > > > > > > > > > > > > > > > On Sat, Aug 23, 2014 at 9:38 PM, Parin Jogani < > parin.jog...@gmail.com> > > > > wrote: > > > > > > > > > Kafka: > > > > > > > > > >> org.apache.kafka > > > > >> kafka_2.9.2 > > > > >> 0.8.1.1 > > > > >> test > > > > > > > > > > > > > > > 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 > > > > > 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.T
Re: kafka unit test in Java, TestUtils choosePort sends NoSuchMethodError
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 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 > wrote: > > > Can anyone help? > > > > > > > > > > On Sat, Aug 23, 2014 at 9:38 PM, Parin Jogani > > wrote: > > > > > Kafka: > > > > > >> org.apache.kafka > > >> kafka_2.9.2 > > >> 0.8.1.1 > > >> test > > > > > > > > > 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 > > 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 > > > >> 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.run
Re: kafka unit test in Java, TestUtils choosePort sends NoSuchMethodError
Can anyone help? On Sat, Aug 23, 2014 at 9:38 PM, Parin Jogani wrote: > Kafka: > >> org.apache.kafka >> kafka_2.9.2 >> 0.8.1.1 >> test > > > 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 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 >> 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 props >> > = TestUtils.createBrokerConfigs(1, true).iterator(); >> > Same result. >> > >> > This is a simple call to create kafka server, dont know what is going >> > wrong. >> > >> > >
Re: kafka unit test in Java, TestUtils choosePort sends NoSuchMethodError
Kafka: > org.apache.kafka > kafka_2.9.2 > 0.8.1.1 > test 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 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 > 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 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 > > 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:7
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 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 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 >>
kafka TestUtils choosePort NoSuchMethodError
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 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
kafka TestUtils createBrokerConfig issue
Trying to write a unit test case for Kafka, and stuck with strange createBrokerConfig issue. on TestUtils.createBrokerConfigs(1) it gives me compilation error The method createBrokerConfigs(int, boolean) in the type TestUtils is not applicable for the arguments (int) When I looked into the scala source code, it contains only two methods: createBrokerConfigs(int) // https://github.com/apache/kafka/blob/0.8.1/core/src/test/scala/unit/kafka/utils/TestUtils.scala#L125 createBrokerConfigs(int, int) //https://github.com/apache/kafka/blob/0.8.1/core/src/test/scala/unit/kafka/utils/TestUtils.scala#L137 Dont understand where this is coming from. -- Regards, Parin
Fwd: kafka TestUtils createBrokerConfig issue
Trying to write a unit test case for Kafka, and stuck with strange createBrokerConfig issue. on TestUtils.createBrokerConfigs(1) it gives me compilation error The method createBrokerConfigs(int, boolean) in the type TestUtils is not applicable for the arguments (int) When I looked into the scala source code, it contains only two methods: createBrokerConfigs(int) // https://github.com/apache/kafka/blob/0.8.1/core/src/test/scala/unit/kafka/utils/TestUtils.scala#L125 createBrokerConfigs(int, int) //https://github.com/apache/kafka/blob/0.8.1/core/src/test/scala/unit/kafka/utils/TestUtils.scala#L137 Dont understand where this is coming from. -- Regards, Parin -- Regards, Parin
kafka TestUtils createBrokerConfig issue
Trying to write a unit test case for Kafka, and stuck with strange createBrokerConfig issue. on TestUtils.createBrokerConfigs(1) it gives me compilation error The method createBrokerConfigs(int, boolean) in the type TestUtils is not applicable for the arguments (int) When I looked into the scala source code, it contains only two methods: createBrokerConfigs(int) // https://github.com/apache/kafka/blob/0.8.1/core/src/test/scala/unit/kafka/utils/TestUtils.scala#L125 createBrokerConfigs(int, int) //https://github.com/apache/kafka/blob/0.8.1/core/src/test/scala/unit/kafka/utils/TestUtils.scala#L137 Dont understand where this is coming from. -- Regards, Parin
