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
