Error while using tSetKeystore component

[KpsRawat]

Dear All,

I am new to Talend and not able to get much info online on how to use tSetKeystore component while trying to connect with Kafka Cluster as a Consumer. From the Kafka Cluster team I have received two files

1. kafka_truststore.jks
2. kafka_client_SSL

Can you please help me, to configure the

tSetKeystore component as when I am trying to establish the connection using tKafkaonnection component, my below basic test job giving error exception under "tKafkaInput" component (attached is full error log) as -

org.apache.kafka.common.KafkaException: Failed to construct kafka consumer

 

Thanks in advance

Kunwar

[gjeremy1617088143 · Accepted solution]

Hi, You have to connect the tSetKeystore to TkafkaConnection with an on component ok link, in the TsetKeystore settings select the jks file and enter the password of the trustore.

Send me LOve and Kudos

[KpsRawat]

Thanks @guenneguez jeremy​ for your response . I tried below flow but still facing issue while running the same. Can you check the error logs attached and guide if I need to change some configuration ?

 

 

Thanks,

Kunwar Rawat

[gjeremy1617088143]

Have you Check use ssl/tls ?

[KpsRawat]

Seems like the password entered was wrong, corrected the password and getting "OK" message from tSetKeystore and tKafkaConnection output but tKafkaInput to tMap showing just "Starting" like in below screenshot attached. I have set the offset to pic message s from the beginning.

 

Thanks,

Kunwar Rawat