topic Catching Kafka Errors / Checking Kafka connection in Talend Studio

Catching Kafka Errors / Checking Kafka connection

Anonymous — Tue, 05 Mar 2019 08:27:07 GMT

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.

Re: Catching Kafka Errors / Checking Kafka connection

Anonymous — Mon, 25 Mar 2019 07:21:21 GMT

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

Re: Catching Kafka Errors / Checking Kafka connection

kariaoua — Thu, 27 Feb 2025 10:04:09 GMT

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