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
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 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 >>
[jira] [Created] (KAFKA-1584) TestUtils createBrokerConfig method argument mismatch
parin jogani created KAFKA-1584: --- Summary: TestUtils createBrokerConfig method argument mismatch Key: KAFKA-1584 URL: https://issues.apache.org/jira/browse/KAFKA-1584 Project: Kafka Issue Type: Bug Components: core Affects Versions: 0.8.1.1 Reporter: parin jogani http://stackoverflow.com/questions/25214015/kafka-testutils-createbrokerconfig-issue -- This message was sent by Atlassian JIRA (v6.2#6252)
[jira] [Updated] (KAFKA-1584) TestUtils createBrokerConfig method argument mismatch
[ https://issues.apache.org/jira/browse/KAFKA-1584?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] parin jogani updated KAFKA-1584: Description: 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. was:http://stackoverflow.com/questions/25214015/kafka-testutils-createbrokerconfig-issue > TestUtils createBrokerConfig method argument mismatch > - > > Key: KAFKA-1584 > URL: https://issues.apache.org/jira/browse/KAFKA-1584 > Project: Kafka > Issue Type: Bug > Components: core >Affects Versions: 0.8.1.1 >Reporter: parin jogani > > 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. -- This message was sent by Atlassian JIRA (v6.2#6252)
