1.概述
2.源码分析
首先看看文章:【kafka】Kafka Fetch Session 剖析
flink 消费 kafka 偶尔会出现这种日志。kafka Error sending fetch request
具体如下【九师兄出品】
根据报错找到报错的位置:org.apache.kafka.clients.FetchSessionHandler#handleError。然后看到代码如下
/**
* Handle an error sending the prepared request.
*



