kafkaFlink消费kafka Error sending fetch request

Posted 九师兄

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了kafkaFlink消费kafka Error sending fetch request相关的知识,希望对你有一定的参考价值。

文章目录


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.
     *
     

以上是关于kafkaFlink消费kafka Error sending fetch request的主要内容,如果未能解决你的问题,请参考以下文章

kafkaFlink 消费 kafka Received unknown topic topic/partition may not exist Describe access to it

kafkaflink 发送 数据到 kafka 报错 Memory records is not writable

kafkaFLink kafka Unable to retrieve any partitions with KafkaTopicsDescriptor: Fixed Topics

kafka之消费超时死循环

kafka一直rebalance故障,重复消费

Flume简介与使用——Kafka Sink消费数据之Kafka安装