Please find the kafka and samza dependencies in the below link https://gist.github.com/debraj-manna/d51af1896d74b68da55f0ef252886692
On Fri, Jun 15, 2018 at 9:14 PM, Martin Gainty <mgai...@hotmail.com> wrote: > unable to determine execution scenario without seeing pom.xml > > > please supply pom.xml > > > Martin > ______________________________________________ > > > > > ________________________________ > From: Debraj Manna <subharaj.ma...@gmail.com> > Sent: Friday, June 15, 2018 11:11 AM > To: users@kafka.apache.org > Subject: Re: NoClassDefFoundError TopicExistxException Samza 0.14.2 and > Kafka 0.10.0.0 > > Martin > > Everything is working fine with samza 0.12. I am now trying to upgrade to > latest samza 0.14.1 which is causing this issue. I am posting the relevant > part from the output of mvn dependency:tree > -Dincludes=org.apache.kafka*,org.apache.samza . > > [INFO] com.vnera.grid.samza-grid:samza-job-package:jar:0.001-SNAPSHOT > [INFO] +- com.vnera.grid.samza-grid:task:jar:0.001-SNAPSHOT:runtime > [INFO] | +- org.apache.samza:samza-api:jar:0.14.1:runtime > [INFO] | \- org.apache.kafka:kafka-clients:jar:0.10.0.0:runtime > [INFO] +- org.apache.samza:samza-shell:tgz:dist:0.14.1:runtime > [INFO] +- org.apache.samza:samza-core_2.11:jar:0.14.1:runtime > [INFO] +- org.apache.samza:samza-yarn_2.11:jar:0.14.1:runtime > [INFO] +- org.apache.samza:samza-kafka_2.11:jar:0.14.1:runtime > [INFO] +- org.apache.samza:samza-kv_2.11:jar:0.14.1:runtime > [INFO] \- org.apache.kafka:kafka_2.11:jar:0.10.0.0:runtime > > On Fri, Jun 15, 2018 at 8:31 PM, Martin Gainty <mgai...@hotmail.com> > wrote: > > > a strong possibility is that kafka-core is missing as a dependency for > > samza > > > > please supply samza pom.xml > > > > > > Martin > > ______________________________________________ > > > > > > > > > > ________________________________ > > From: Debraj Manna <subharaj.ma...@gmail.com> > > Sent: Friday, June 15, 2018 10:52 AM > > To: users@kafka.apache.org > > Subject: NoClassDefFoundError TopicExistxException Samza 0.14.2 and Kafka > > 0.10.0.0 > > > > Hi > > > > I have posted the same in d...@samza.apache.org , posting it here also if > > anyone is aware. > > > > *I am trying to use samza 0.14.2 with Kafka Client 0.10.0 . I am getting > > the below exception. Is this related > > to https://issues.apache.org/jira/browse/SAMZA-1509 > > <https://issues.apache.org/jira/browse/SAMZA-1509>. ? Is samza 0.14.2 > not > > compatible with 0.10 Kafka ? The same code was working fine with samza > > 0.12. * > > > > 2018-06-15 13:47:29.228 [main] ZooKeeper [INFO] Session: > 0x164031c68f3030a > > closed > > Exception in thread "main" java.lang.NoClassDefFoundError: > > org/apache/kafka/common/errors/TopicExistsException > > at org.apache.samza.system.kafka.KafkaSystemAdmin$$anonfun$ > > createStream$3.apply(KafkaSystemAdmin.scala:467) > > at org.apache.samza.system.kafka.KafkaSystemAdmin$$anonfun$ > > createStream$3.apply(KafkaSystemAdmin.scala:465) > > at org.apache.samza.util.ExponentialSleepStrategy.run( > > ExponentialSleepStrategy.scala:89) > > at org.apache.samza.system.kafka.KafkaSystemAdmin.createStream( > > KafkaSystemAdmin.scala:447) > > at org.apache.samza.job.JobRunner.run(JobRunner.scala:92) > > at org.apache.samza.job.JobRunner$.doOperation(JobRunner.scala:53) > > at org.apache.samza.job.JobRunner$.main(JobRunner.scala:48) > > at org.apache.samza.job.JobRunner.main(JobRunner.scala) > > Caused by: java.lang.ClassNotFoundException: org.apache.kafka.common. > > errors.TopicExistsException > > at java.net.URLClassLoader.findClass(URLClassLoader.java:381) > > at java.lang.ClassLoader.loadClass(ClassLoader.java:424) > > at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:338) > > at java.lang.ClassLoader.loadClass(ClassLoader.java:357) > > ... 8 more > > >
