Hi! I am new to the community. So pardon me for any mistake I make. I am running a test where I bring all my kafka brokers down at once and bring them up after 10 mins. I was expecting the Kafka Source Reader to reconnect back without any issue but its not connecting back and has entered in some loop of errors. I have attached SO link more detail. Anyone has any idea of how i can mitigate this problem. https://stackoverflow.com/questions/76998148/flink-kafka-source-operator-reconnect-issue?noredirect=1#comment135741744_76998148

It’s better to not cross post, but what’s your restart strategy? https://nightlies.apache.org/flink/flink-docs-release-1.17/docs/ops/state/task_failure_recovery/

The problem is disconnection issues are not considered as task failures. I have configured the restart strategy as fixed-delay with 3 retries after a gap of 10sec. And failover strategy as full restart. Do note the job status shows as RUNNING. While the jm logs shows disconnection logs, In the dashboard The job does not show any exceptions in its Exception tab.