apache-kafka - I/O 中的 Kafka 错误 java.io.EOFException : null

Question

我正在使用 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)

Answer 1

这对派对来说有点晚，但可能会帮助某人 - 它会帮助我。

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

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

更多详情:https://issues.apache.org/jira/browse/KAFKA-3205

代理配置记录在此处: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

希望有帮助。