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