Flink Kafka Connection Failure Notifications

[chiggi_dev]

Hi,

I am using Flink 1.7.2 with Kafka Connector 0.11 for Consuming records from Kafka. 

I observed that if the broker is down, Kafka Consumer does nothing but logs the connection error and keeps on reconnecting to the broker. And infact the log level seems to be DEBUG. 

Is there any way to capture such connection failures with the Flink APIs? 

Or maybe restart the job if the connection is not successful?

Thanks,

Chirag