You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user-zh@flink.apache.org by x <35...@qq.com> on 2020/10/26 07:19:13 UTC

求助：kafka broker 宕机重启后，程序卡住无法继续

kafka版本0.10.1.1，flink版本1.10.1
信息如下：
2020-10-24&nbsp;21:52:44,053&nbsp;INFO&nbsp;&nbsp;org.apache.flink.kafka.shaded.org.apache.kafka.clients.FetchSessionHandler&nbsp;&nbsp;-&nbsp;[Consumer&nbsp;clientId=consumer-12,&nbsp;groupId=onlineTag]&nbsp;Error&nbsp;sending&nbsp;fetch&nbsp;request&nbsp;(sessionId=INVALID,&nbsp;epoch=INITIAL)&nbsp;to&nbsp;node&nbsp;10:&nbsp;org.apache.flink.kafka.shaded.org.apache.kafka.common.errors.DisconnectException.
2020-10-24&nbsp;21:53:13,254&nbsp;INFO&nbsp;&nbsp;org.apache.flink.kafka.shaded.org.apache.kafka.clients.FetchSessionHandler&nbsp;&nbsp;-&nbsp;[Consumer&nbsp;clientId=consumer-20,&nbsp;groupId=onlineTag]&nbsp;Error&nbsp;sending&nbsp;fetch&nbsp;request&nbsp;(sessionId=INVALID,&nbsp;epoch=INITIAL)&nbsp;to&nbsp;node&nbsp;11:&nbsp;org.apache.flink.kafka.shaded.org.apache.kafka.common.errors.DisconnectException.