flink sql 消费kafka,断开连接

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

flink sql 消费kafka,断开连接

smailxie






有人遇到过这种错吗?kafka一直连不上。但是报错的只是某个topic,其他topic是可以的。


2020-12-1110:51:04,446INFO org.apache.kafka.clients.FetchSessionHandler [] - [Consumer clientId=consumer-v2.realtime.sales.offline.group-23, groupId=v2.realtime.sales.offline.group] Error sending fetch request (sessionId=INVALID, epoch=INITIAL) to node 2: {}.
org.apache.kafka.common.errors.DisconnectException: null
2020-12-1110:52:03,213INFO org.apache.kafka.clients.FetchSessionHandler [] - [Consumer clientId=consumer-v2.realtime.sales.offline.group-23, groupId=v2.realtime.sales.offline.group] Error sending fetch request (sessionId=INVALID, epoch=INITIAL) to node 5: {}.
org.apache.kafka.common.errors.DisconnectException: null