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 claylin <10...@qq.com> on 2020/02/21 07:58:01 UTC

关于mq消息堆积引发的消费者断开连接异常

Hi 大家好：这边出现个现象，这边采用event time运行作业，数据源是从kafka消费数据，运行期间发生了tcp消息堆积(消费者tcp接受队列Recv-Q消息堆积)，发生反压是是正常现象，但是不知道为什么也发生了消费者超时，断开连接的错误：
org.apache.kafka.clients.FetchSessionHandler&nbsp; - [Consumer clientId=consumer-108, groupId=push-life-cycle-trace-consumer-for-flink-1.1.0-no-checkpoint] Error sending fetch request (sessionId=INVALID, epoch=INITIAL) to node 213: org.apache.kafka.common.errors.DisconnectException.


我想问下消息堆积，为什么会导致消费者超时，断开连接的错误