我们的Apache kafka环境具有1-zk，3-服务器。每个服务器上的堆大小为1800 MB。我正在尝试生成1000mb，20mb的文件，以查看Kafka的性能。
我正进入（状态：
[PDT] 2015-03-23 13:53:50选择器[WARN]主机的I / O错误
java.io.EOFException
在org.apache.kafka.common.network.NetworkReceive.readFrom（NetworkReceive.java:62）
在org.apache.kafka.common.network.Selector.poll（Selector.java:248）
在org.apache.kafka.clients.NetworkClient.poll（NetworkClient.java:192）
在org.apache.kafka.clients.producer.internals.Sender.run（Sender.java:191）
在org.apache.kafka.clients.producer.internals.Sender.run（Sender.java:122）
在java.lang.Thread.run（Thread.java:724）
我有时会收到第997条消息，有时会收到第999条消息。没有模式。
谢谢，感谢您的宝贵时间！
最佳答案
这已经在这里解决了https://issues.apache.org/jira/browse/KAFKA-3205
尝试增加代理配置中的connections.max.idle.ms（kafka 0.9中的代理默认为10分钟）
关于apache-kafka - Apache Kafka 8.2中带有主机java.io.EOFException的I/O中的选择器[WARN]错误，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/29221068/