Sent: Wednesday, August 16, 2017 12:27 PM
To: dev@samza.apache.org
Subject: Re: Issue with TopicExistsException in 0.13.0
Jacob,
We are getting closer. The job will attempt to run before falling over. The
logs show it going through VerifiableProperties and connecting to the brokers
and quietly
from 10.201.10.222:9092
Jeremiah Adams
Software Engineer
www.helixeducation.com
Blog | Twitter | Facebook | LinkedIn
From: Jacob Maes
Sent: Tuesday, August 15, 2017 9:23 AM
To: dev@samza.apache.org
Subject: Re: Issue with TopicExistsException in 0.13.0
on.com
> Blog | Twitter | Facebook | LinkedIn
>
> ________
> From: Jacob Maes
> Sent: Monday, August 14, 2017 3:12 PM
> To: dev@samza.apache.org
> Subject: Re: Issue with TopicExistsException in 0.13.0
>
> Correction, the exc
e Engineer
www.helixeducation.com
Blog | Twitter | Facebook | LinkedIn
From: Jacob Maes
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 moved between kaf
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:
https://github.com/apache/samza/commit/9db47b86120f80b127d2bca857b6a1cd5578a6d4#diff-2beed65293202568c54
Hey Jeremiah,
It looks like the TopicExistsException should be handled by the system
admin and not rethrown:
https://github.com/apache/samza/blob/06702af8fda1d016ae55461c404b55b84b20ffd2/samza-kafka/src/main/scala/org/apache/samza/system/kafka/KafkaSystemAdmin.scala#L442
I have a theory what's ha
