具体是什么样的 exception?Kafka 的重连和 Task 重启是不同的事情。前者取决于 Kafka 的配置和异常的类型,后者取决于 Flink 的重启策略。
Best, Paul Lam > 2020年9月11日 11:42,[email protected] > <[email protected]> 写道: > > 自己顶一下, 有人给些建议吗? > > > > -- > Sent from: http://apache-flink.147419.n8.nabble.com/
具体是什么样的 exception?Kafka 的重连和 Task 重启是不同的事情。前者取决于 Kafka 的配置和异常的类型,后者取决于 Flink 的重启策略。
Best, Paul Lam > 2020年9月11日 11:42,[email protected] > <[email protected]> 写道: > > 自己顶一下, 有人给些建议吗? > > > > -- > Sent from: http://apache-flink.147419.n8.nabble.com/