You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@samza.apache.org by Debraj Manna <su...@gmail.com> on 2018/06/15 14:44:23 UTC
NoClassDefFoundError TopicExistxException Samza 0.14.2 and Kafka 0.10
Hi
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. ? Is samza 0.14.2 not
compatible with 0.10 Kafka ?
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
Posted by Yi Pan <ni...@gmail.com>.
Awesome! Glad to hear that!
-Yi
On Tue, Jun 26, 2018 at 12:28 PM, Debraj Manna <su...@gmail.com>
wrote:
> Hi Yi
>
> Yes it is working fine after upgrade to 0.11.
>
> On Tue 26 Jun, 2018, 11:24 PM Yi Pan, <ni...@gmail.com> wrote:
>
> > Hi, Debraj,
> >
> > Were you able to try the upgrade? Any further help that you need?
> >
> > Thanks!
> >
> > -Yi
> >
> > On Fri, Jun 15, 2018 at 3:32 PM, Yi Pan <ni...@gmail.com> wrote:
> >
> > > Hi, Debraj,
> > >
> > > For Samza 0.14.1, we have moved to Kafka 0.11.0.2. Please try to use
> the
> > > new Kafka version and let us know whether you have problem upgrading or
> > not.
> > >
> > > Thanks a lot!
> > >
> > > -Yi
> > >
> > > On Fri, Jun 15, 2018 at 8:13 AM, Debraj Manna <
> subharaj.manna@gmail.com>
> > > wrote:
> > >
> > >> Just to add 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.
> > >>
> > >> On Fri, Jun 15, 2018 at 8:14 PM, Debraj Manna <
> subharaj.manna@gmail.com
> > >
> > >> wrote:
> > >>
> > >> > Hi
> > >> >
> > >> > 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. ? Is samza 0.14.2 not compatible with 0.10
> > >> Kafka ?
> > >> >
> > >> > 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
Posted by Debraj Manna <su...@gmail.com>.
Hi Yi
Yes it is working fine after upgrade to 0.11.
On Tue 26 Jun, 2018, 11:24 PM Yi Pan, <ni...@gmail.com> wrote:
> Hi, Debraj,
>
> Were you able to try the upgrade? Any further help that you need?
>
> Thanks!
>
> -Yi
>
> On Fri, Jun 15, 2018 at 3:32 PM, Yi Pan <ni...@gmail.com> wrote:
>
> > Hi, Debraj,
> >
> > For Samza 0.14.1, we have moved to Kafka 0.11.0.2. Please try to use the
> > new Kafka version and let us know whether you have problem upgrading or
> not.
> >
> > Thanks a lot!
> >
> > -Yi
> >
> > On Fri, Jun 15, 2018 at 8:13 AM, Debraj Manna <su...@gmail.com>
> > wrote:
> >
> >> Just to add 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.
> >>
> >> On Fri, Jun 15, 2018 at 8:14 PM, Debraj Manna <subharaj.manna@gmail.com
> >
> >> wrote:
> >>
> >> > Hi
> >> >
> >> > 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. ? Is samza 0.14.2 not compatible with 0.10
> >> Kafka ?
> >> >
> >> > 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
Posted by Yi Pan <ni...@gmail.com>.
Hi, Debraj,
Were you able to try the upgrade? Any further help that you need?
Thanks!
-Yi
On Fri, Jun 15, 2018 at 3:32 PM, Yi Pan <ni...@gmail.com> wrote:
> Hi, Debraj,
>
> For Samza 0.14.1, we have moved to Kafka 0.11.0.2. Please try to use the
> new Kafka version and let us know whether you have problem upgrading or not.
>
> Thanks a lot!
>
> -Yi
>
> On Fri, Jun 15, 2018 at 8:13 AM, Debraj Manna <su...@gmail.com>
> wrote:
>
>> Just to add 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.
>>
>> On Fri, Jun 15, 2018 at 8:14 PM, Debraj Manna <su...@gmail.com>
>> wrote:
>>
>> > Hi
>> >
>> > 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. ? Is samza 0.14.2 not compatible with 0.10
>> Kafka ?
>> >
>> > 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
Posted by Yi Pan <ni...@gmail.com>.
Hi, Debraj,
For Samza 0.14.1, we have moved to Kafka 0.11.0.2. Please try to use the
new Kafka version and let us know whether you have problem upgrading or not.
Thanks a lot!
-Yi
On Fri, Jun 15, 2018 at 8:13 AM, Debraj Manna <su...@gmail.com>
wrote:
> Just to add 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.
>
> On Fri, Jun 15, 2018 at 8:14 PM, Debraj Manna <su...@gmail.com>
> wrote:
>
> > Hi
> >
> > 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. ? Is samza 0.14.2 not compatible with 0.10 Kafka
> ?
> >
> > 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
Posted by Debraj Manna <su...@gmail.com>.
Just to add 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.
On Fri, Jun 15, 2018 at 8:14 PM, Debraj Manna <su...@gmail.com>
wrote:
> Hi
>
> 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. ? Is samza 0.14.2 not compatible with 0.10 Kafka ?
>
> 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
>