You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@kafka.apache.org by Debraj Manna <su...@gmail.com> on 2018/06/15 14:52:37 UTC
NoClassDefFoundError TopicExistxException Samza 0.14.2 and Kafka 0.10.0.0
Hi
I have posted the same in dev@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
Re: new pom.xml for samza-parent-project
Posted by Debraj Manna <su...@gmail.com>.
Thanks Martin for looking into this.
On Sun, Jun 17, 2018 at 4:33 PM, Martin Gainty <mg...@hotmail.com> wrote:
> you're welcome
>
>
> bye
> ______________________________________________
>
>
>
> ------------------------------
> *From:* Debraj Manna <su...@gmail.com>
> *Sent:* Sunday, June 17, 2018 4:25 AM
> *To:* Martin Gainty
> *Cc:* users@kafka.apache.org
> *Subject:* Re: new pom.xml for samza-parent-project
>
> 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, <mg...@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 <mg...@hotmail.com>
> *Sent:* Friday, June 15, 2018 5:25 PM
> *To:* users@kafka.apache.org; subharaj.manna@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 <su...@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 <mg...@hotmail.com>
> wrote:
>
> > unable to determine execution scenario without seeing pom.xml
> >
> >
> > please supply pom.xml
> >
> >
> > Martin
> > ______________________________________________
> >
> >
> >
> >
> > ________________________________
> > From: Debraj Manna <su...@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 <mg...@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 <su...@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 dev@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
> > >
> >
>
>
Re: new pom.xml for samza-parent-project
Posted by Debraj Manna <su...@gmail.com>.
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, <mg...@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 <mg...@hotmail.com>
> *Sent:* Friday, June 15, 2018 5:25 PM
> *To:* users@kafka.apache.org; subharaj.manna@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 <su...@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 <mg...@hotmail.com>
> wrote:
>
> > unable to determine execution scenario without seeing pom.xml
> >
> >
> > please supply pom.xml
> >
> >
> > Martin
> > ______________________________________________
> >
> >
> >
> >
> > ________________________________
> > From: Debraj Manna <su...@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 <mg...@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 <su...@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 dev@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
> > >
> >
>
new pom.xml for samza-parent-project
Posted by Martin Gainty <mg...@hotmail.com>.
Martin Gainty has shared a OneDrive file with you. To view it, click the link below.
<https://1drv.ms/u/s!AkpuiYcNg4cShUb8oiOENPhRhIUV>
[https://r1.res.office365.com/owa/prem/images/dc-generic_20.png]<https://1drv.ms/u/s!AkpuiYcNg4cShUb8oiOENPhRhIUV>
pom 1.xml<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 <mg...@hotmail.com>
Sent: Friday, June 15, 2018 5:25 PM
To: users@kafka.apache.org; subharaj.manna@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 <su...@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://avatars2.githubusercontent.com/u/8141860?s=400&v=4]<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 <mg...@hotmail.com> wrote:
> unable to determine execution scenario without seeing pom.xml
>
>
> please supply pom.xml
>
>
> Martin
> ______________________________________________
>
>
>
>
> ________________________________
> From: Debraj Manna <su...@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 <mg...@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 <su...@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 dev@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
> >
>
new pom.xml for samza-grid
Posted by Martin Gainty <mg...@hotmail.com>.
Martin Gainty has shared a OneDrive file with you. To view it, click the link below.
<https://1drv.ms/u/s!AkpuiYcNg4cShUUyzyKvQmvyNPuk>
[https://r1.res.office365.com/owa/prem/images/dc-generic_20.png]<https://1drv.ms/u/s!AkpuiYcNg4cShUUyzyKvQmvyNPuk>
pom.xml<https://1drv.ms/u/s!AkpuiYcNg4cShUUyzyKvQmvyNPuk>
[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 <su...@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://avatars2.githubusercontent.com/u/8141860?s=400&v=4]<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 <mg...@hotmail.com> wrote:
> unable to determine execution scenario without seeing pom.xml
>
>
> please supply pom.xml
>
>
> Martin
> ______________________________________________
>
>
>
>
> ________________________________
> From: Debraj Manna <su...@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 <mg...@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 <su...@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 dev@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
> >
>
Re: NoClassDefFoundError TopicExistxException Samza 0.14.2 and Kafka 0.10.0.0
Posted by Debraj Manna <su...@gmail.com>.
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 <mg...@hotmail.com> wrote:
> unable to determine execution scenario without seeing pom.xml
>
>
> please supply pom.xml
>
>
> Martin
> ______________________________________________
>
>
>
>
> ________________________________
> From: Debraj Manna <su...@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 <mg...@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 <su...@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 dev@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
> >
>
Re: NoClassDefFoundError TopicExistxException Samza 0.14.2 and Kafka
0.10.0.0
Posted by Martin Gainty <mg...@hotmail.com>.
unable to determine execution scenario without seeing pom.xml
please supply pom.xml
Martin
______________________________________________
________________________________
From: Debraj Manna <su...@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 <mg...@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 <su...@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 dev@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
>
Re: NoClassDefFoundError TopicExistxException Samza 0.14.2 and Kafka 0.10.0.0
Posted by Debraj Manna <su...@gmail.com>.
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 <mg...@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 <su...@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 dev@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
>
Re: NoClassDefFoundError TopicExistxException Samza 0.14.2 and Kafka
0.10.0.0
Posted by Martin Gainty <mg...@hotmail.com>.
a strong possibility is that kafka-core is missing as a dependency for samza
please supply samza pom.xml
Martin
______________________________________________
________________________________
From: Debraj Manna <su...@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 dev@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