Awesome! Glad to hear that! -Yi
On Tue, Jun 26, 2018 at 12:28 PM, Debraj Manna <subharaj.ma...@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, <nickpa...@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 <nickpa...@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.ma...@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.ma...@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 > > >> > > > >> > > > > > > > > >
