【kafka】Flink消费kafka Error sending fetch request

作者：2023面试高手 | 2024-06-08 18:35:54

踩

error sending fetch request

文章目录

1.概述
2.源码分析
3.场景2

1.概述

首先看看文章：【kafka】Kafka Fetch Session 剖析

flink 消费 kafka 偶尔会出现这种日志。kafka Error sending fetch request

具体如下【九师兄出品】
在这里插入图片描述

2.源码分析

根据报错找到报错的位置：org.apache.kafka.clients.FetchSessionHandler#handleError。然后看到代码如下

  /**
     * Handle an error sending the prepared request.
     *
     * 处理发送已准备请求的错误。
     *
     * When a network error occurs, we close any existing fetch session on our next request1
2
3
4
5

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/2023面试高手/article/detail/690767