Re: Issue with TopicExistsException in 0.13.0

2017-08-16 Thread Jeremiah Adams
container_1502753192195_0007_02_01]$ > > > > > Jeremiah Adams > Software Engineer > https://url.serverdata.net/?ahfhEufaAWbezBrUFPG98ZJcterGfIerU3ZwsA3Gv_C0~ > Blog | Twitter | Facebook | LinkedIn > > ____ > From: Jacob Maes

Re: Issue with TopicExistsException in 0.13.0

2017-08-15 Thread Jacob Maes
eer > www.helixeducation.com > Blog | Twitter | Facebook | LinkedIn > > ________ > From: Jacob Maes <jacob.m...@gmail.com> > Sent: Monday, August 14, 2017 3:12 PM > To: dev@samza.apache.org > Subject: Re: Issue with TopicExistsExceptio

Re: Issue with TopicExistsException in 0.13.0

2017-08-15 Thread Jeremiah Adams
www.helixeducation.com Blog | Twitter | Facebook | LinkedIn From: Jacob Maes <jacob.m...@gmail.com> Sent: Monday, August 14, 2017 3:12 PM To: dev@samza.apache.org Subject: Re: Issue with TopicExistsException in 0.13.0 Correction, the exception seems to have

Re: Issue with TopicExistsException in 0.13.0

2017-08-14 Thread Jacob Maes
Correction, the exception seems to have moved between kafka version 0.10.0.1 and 0.10.1.1 Here's the patch that changed both the kafka version and the import statement for TopicExistsException:

Issue with TopicExistsException in 0.13.0

2017-08-14 Thread Jeremiah Adams
I am having an issue with topic creation after updating dependencies. I bumped samza dependencies from scala 2.10 v 0.10.1 to scala 2.11 0.13.0 and org.apache.kafka dependency from kafka_2.10 0.8.1 to kafka_2.11 0.10.1.1. I am seeing an error that the topic already exists and the job gets stuck