tKafkaCreateTopic (TopicExistsException) Error

[sensiva]

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

[Anonymous]

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?

 Best regards

Sabrina

[Anonymous]

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)