This has been answered in samza mailing list. http://mail-archives.apache.org/mod_mbox/samza-dev/201806.mbox/ <CAFvExu1ybyTf5yrBP%2Bi%2BSuUL-_Ht4SuxtztE1fShSjeGuJkSNQ%40mail.gmail.com>
Samza 0.14.x moved to Kafka 0.11. On Sat 16 Jun, 2018, 3:04 AM Martin Gainty, <mgai...@hotmail.com> wrote: > Martin Gainty has shared a OneDrive file with you. To view it, click the > link below. > <https://1drv.ms/u/s!AkpuiYcNg4cShUb8oiOENPhRhIUV> > pom 1.xml <https://1drv.ms/u/s!AkpuiYcNg4cShUb8oiOENPhRhIUV> > <https://1drv.ms/u/s!AkpuiYcNg4cShUb8oiOENPhRhIUV> > > >mvn dependency:tree > > [INFO] > ------------------------------------------------------------------------ > [INFO] Reactor Summary: > [INFO] > [INFO] Samza Job Parent ................................... SUCCESS [ > 4.798 s] > [INFO] Samza Job Parent 0.001-SNAPSHOT .................... SUCCESS [ > 0.407 s] > [INFO] > ------------------------------------------------------------------------ > [INFO] BUILD SUCCESS > [INFO] > ------------------------------------------------------------------------ > [INFO] Total time: 5.925 s > [INFO] Finished at: 2018-06-15T17:28:04-04:00 > [INFO] > ------------------------------------------------------------------------ > > attached new pom.xml for samza-parent-project (parent of samza-grid) > > be sure to supply <version> that conforms to your project in pom.xml > > directory structure should look like: > > > samza-parent-project > > | > > ---------------------samza-grid > > Have Fun > > > Martin > ______________________________________________ > > _____ _ _____ _ _____ ___ _ > _____ _ _ _ |_ _| |_ ___ | _ |___ > ___ ___| |_ ___ | __|___| _| |_ _ _ _ ___ ___ ___ | __|___ _ _ ___ > _| |___| |_|_|___ ___ | | | | -_| | | . | .'| _| | -_| |__ | > . | _| _| | | | .'| _| -_| | __| . | | | | . | .'| _| | . | | > |_| |_|_|___| |__|__| _|__,|___|_|_|___| |_____|___|_| |_| |_____|__,|_| > |___| |__| |___|___|_|_|___|__,|_| |_|___|_|_| |_| > > > > > ------------------------------ > *From:* Martin Gainty <mgai...@hotmail.com> > *Sent:* Friday, June 15, 2018 5:25 PM > *To:* users@kafka.apache.org; subharaj.ma...@gmail.com > *Subject:* new pom.xml for samza-grid > > > [INFO] > ------------------------------------------------------------------------ > [INFO] BUILD SUCCESS > [INFO] > ------------------------------------------------------------------------ > [INFO] Total time: 3.006 s > [INFO] Finished at: 2018-06-15T17:20:09-04:00 > [INFO] > ------------------------------------------------------------------------ > > > kafka-grid pom.xml attached > > change <version> to the specific version you want to declare > > > Martin > ______________________________________________ > > _____ _ _____ _ _____ ___ _ > _____ _ _ _ |_ _| |_ ___ | _ |___ > ___ ___| |_ ___ | __|___| _| |_ _ _ _ ___ ___ ___ | __|___ _ _ ___ > _| |___| |_|_|___ ___ | | | | -_| | | . | .'| _| | -_| |__ | > . | _| _| | | | .'| _| -_| | __| . | | | | . | .'| _| | . | | > |_| |_|_|___| |__|__| _|__,|___|_|_|___| |_____|___|_| |_| |_____|__,|_| > |___| |__| |___|___|_|_|___|__,|_| |_|___|_|_| |_| > > > > > ------------------------------ > *From:* Debraj Manna <subharaj.ma...@gmail.com> > *Sent:* Friday, June 15, 2018 12:03 PM > *To:* users@kafka.apache.org > *Subject:* Re: NoClassDefFoundError TopicExistxException Samza 0.14.2 and > Kafka 0.10.0.0 > > Please find the kafka and samza dependencies in the below link > https://gist.github.com/debraj-manna/d51af1896d74b68da55f0ef252886692 > <https://gist.github.com/debraj-manna/d51af1896d74b68da55f0ef252886692> > Kafka Samza > <https://gist.github.com/debraj-manna/d51af1896d74b68da55f0ef252886692> > gist.github.com > Kafka Samza > > > > 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 > > > > > >