Catching Kafka Errors / Checking Kafka connection

[Anonymous]

Hi All, 

I'm new to working with Talend. I have come across a peculiar problem in talend, is that when I'm using the tKafkaInput, tKafkaConnection components , I'm unable to catch the errors. tKafkaInput does not throw any error when there is a Kafka outage. 

I've tried using component triggers (subjob/component) (ok/error ) style with tDie and it does not catch the exceptions.

How can I handle these scenarios and catch exceptions when there is a Kafka outage when using Kafka components or keep checking for the health of Kafka .

Any help would be appreciated.

[Anonymous]

Hello,

Are you referring to this kind of kafka issue?

java.net.ConnectException: Connection refused

  What's Kafka client are you using?

Best regards

Sabrina

[kariaoua]

I have the same issue, do you have a solution to this ?