tKafkaCreateTopic (TopicExistsException) Error

Six Stars

tKafkaCreateTopic (TopicExistsException) Error

Hello,

 

I am trying to create a topic in kafka using the tKafkaCreateTopic component. But I get this error during build "Detail Message: kafka.common.TopicExistsException cannot be resolved to a type"

 

And i dont see TopicExistsException class under common in the kafka jar.

 

The version of kafka being used is kafka_2.11-1.0.0, but the kafka version chosen in BigData Studio is kafka0.10.0.1, but nevertheless, i haven't seen a change in kafka jar packaging between these version, hence we should be good.

 

Am i missing any jar here or is it that the talend component should be referring to kafka.common.errors.TopicExistsException. I refered this link https://kafka.apache.org/0110/javadoc/org/apache/kafka/common/errors/TopicExistsException.html

Moderator

Re: tKafkaCreateTopic (TopicExistsException) Error

Hello,

It looks like the issue is with jar files. Could you please clarify in which Talend bigdata version/edition you are? Have you already installed required external modules for component tKafkaCreateTopic?

1.png

 Best regards

Sabrina

--
Don't forget to give kudos when a reply is helpful and click Accept the solution when you think you're good with it.
Four Stars

Re: tKafkaCreateTopic (TopicExistsException) Error

Hello,
The supported version of Kafka is listed here:
https://help.talend.com/reader/1V5U6CVzPxVZHFWPIIKB1g/b_qVBTTIBMSa9YR0uV91pg
I guess you have to go back to Kafka 0.10 (also me)