I/O java.io.EOFException 中的 Kafka 错误：null答案

【问题标题】：Kafka Error in I/O java.io.EOFException: nullI/O java.io.EOFException 中的 Kafka 错误：null
【发布时间】：2021-09-02 18:05:52
【问题描述】：

我正在使用 Kafka 0.8.2.0 (Scala 2.10)。在我的日志文件中，我间歇性地看到以下消息。这似乎是一个连接问题，但我都在我的本地主机中运行。

这是无害的警告信息还是我应该采取措施避免它？

2015-10-30 14:12:38.015  WARN 4251 --- [ad | producer-1] [                                    ] o.apache.kafka.common.network.Selector   : Error in I/O with localhost/127.0.0.1

java.io.EOFException: null
    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)

【问题讨论】：

标签： apache-kafka

【解决方案1】：

这在聚会上有点晚了，但可能对某人有所帮助 - 它会对我有所帮助。

您看到的情况是因为 Kafka 代理在超过一定的空闲时间后被动关闭连接。它由这个代理属性定义：connections.max.idle.ms - 默认为 10 分钟。

显然 0.8.x 中的 kafka 客户端不支持该设置，只是让空闲连接保持打开状态。您会在日志中看到警告，但它应该不会对您的应用程序产生不良影响。

代理配置记录在这里：https://kafka.apache.org/090/documentation/#configuration

在该表中，您会发现：

Name: connections.max.idle.ms
Description: Idle connections timeout: the server socket processor threads close the connections that idle more than this
Type:long
Default: 600000

希望对您有所帮助。

【讨论】：

【解决方案2】：

我在使用 0.8 的 Kafka 代理运行 Kafka 流应用程序时遇到了这个问题

我已尝试更改上述答案中@Phil Brock 提供的配置。但这似乎对它没有任何影响。

升级 Kafka 代理 到 2.x 似乎只是对我来说可行的解决方案。

当我寻找 Kafka 流版本兼容性时，我得到了这个

请注意，代理必须是 0.10 版本。 1 或更高版本以运行 Kafka Streams 应用程序版本 0.10。 1或更高；磁盘消息格式必须为 0.10 或更高版本才能运行 Kafka Streams 应用程序版本 1.0 或更高版本。

【讨论】：

【解决方案3】：

您的生产者似乎无法连接到 kafka 代理。我建议您尝试向 kafka 控制台生产者发送一些消息，以验证您的系统配置是否正确。

【讨论】：

问题是它工作正常，虽然我看到了这条消息。此消息随机出现。但到目前为止，该应用程序运行良好。只是担心会随机出现这个异常。
@YohanLiyanage 我明白了，事实上 kafka 记录了很多信息。