tion to kafka related configurations.
>
>
> Best
> Yun Tang
> ----------
> *From:* Siddhesh Kalgaonkar
> *Sent:* Wednesday, January 26, 2022 3:17
> *To:* user
> *Subject:* Failure Restart Strategy leads to error
>
> I have Flink Kafka Consumer i
: Siddhesh Kalgaonkar
Sent: Wednesday, January 26, 2022 3:17
To: user
Subject: Failure Restart Strategy leads to error
I have Flink Kafka Consumer in place which works fine until I add the below
lines:
env.setRestartStrategy(RestartStrategies.failureRateRestart(
3, // max failures per unit
I have Flink Kafka Consumer in place which works fine until I add the below
lines:
env.setRestartStrategy(RestartStrategies.failureRateRestart(
3,
*// max failures per unit* Time.of(5, TimeUnit.MINUTES),
*//time interval for measuring failure rate* Time.of(10, TimeUnit.SECONDS)
*// delay*))
It