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.
