当前位置:首页 > 后端开发 > Kafka EOFException解决办法

Kafka EOFException解决办法

7个月前 (05-21)65
异常如下

java.io.EOFException
	at org.apache.kafka.common.network.NetworkReceive.readFrom(NetworkReceive.java:62)
	at org.apache.kafka.common.network.Selector.poll(Selector.java:248)
	at org.apache.kafka.clients.NetworkClient.poll(NetworkClient.java:192)
	at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:191)
	at org.apache.kafka.clients.producer.internals.Sender.run(Sender.java:122)
	at java.lang.Thread.run(Thread.java:745)

kafka 在0.82客户端中空闲链接因为超时 但未被客户端关闭会引起EOFException  此链接链接服务端失败 若配置了重试  客户端将会重试  不影响正常消费  可以增大connections.max.idle.ms参数值  默认15分钟 增大超时时间  可减少该错误日志 或客户端升级到0.9+该问题能得到解决

 https://issues.apache.org/jira/browse/KAFKA-3205

作者:dingyufei615
来源链接:https://blog.csdn.net/dingyufei615/article/details/103044554

标签: Kafka

“Kafka EOFException解决办法” 的相关文章

CentOS 搭建Kafka集群

CentOS 搭建Kafka集群

        目录      &nb...

kafka安装及配置

kafka安装及配置

一、下载安装 1、下载地址 https://www.apache.org/dyn/closer.cgi?path=/kafka/2.4.0/kafka_2.13-...

Centos安装Kafka集群

Centos安装Kafka集群

kafka是LinkedIn开发并开源的一个分布式MQ系统,现在是Apache的一个孵化项目。在它的主页描述kafka为一个高吞吐量的分布式(能将消息分散到不同的节点上)MQ。在这片博文...

java检测kafka是否连接成功,kafka代码测试连接

1.发送: package kafka.test; import java.util.Date; import java.util.Prop...

kafka 配置文件参数详解

kafka的配置分为 broker、producter、consumer三个不同的配置 一 BROKER 的全局配置 最为核心的三个配置 broker.id、log.dir、...

大数据新手之路三:安装Kafka

大数据新手之路三:安装Kafka Ubuntu16.04+Kafka1.0.0   1.下载kafka_2.11-1.0.0.tgz htt...

Linux安装Kafka

Linux安装Kafka

本文介绍Linux安装Kafka。 1.Kafka简介 Kafka也是开源与Apache开源基金会的项目,由Scala和Java编写。Kafka是一种高吞吐...

kafka配置步骤整理

kafka配置步骤整理

目录 一、参考 二、java jdk安装配置 三、Zookeeper安装配置 四、Kafka集群搭建 五、测试验证   一...

centos7下docker-compose安装kafka集群

  0 安装docker(略) 1. 安装docker-compose 1、下载安装文件 curl -L https://github...

kafka详细教程

kafka详细教程

【仅需9.9订阅专栏合集,作者所有付费文章都能看】 推荐【Kafka教程】https://bigbird.blog.csdn.net/arti...