你好。 当connector连接kafka,如果某个message出现exception时,task就停了, 没有自动重新连接, 看了kafka connector的配置,没有这方面的设置,这个有什么重连机制吗? Thanks.
-- Sent from: http://apache-flink.147419.n8.nabble.com/
你好。 当connector连接kafka,如果某个message出现exception时,task就停了, 没有自动重新连接, 看了kafka connector的配置,没有这方面的设置,这个有什么重连机制吗? Thanks.
-- Sent from: http://apache-flink.147419.n8.nabble.com/