Apache Flink 中文用户邮件列表

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

Classic

List

Threaded

1 message

x_gothicist

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

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