Our Apache kafka environment has 1 - zk, 3 - servers. heap size of 1800 MB on each server. I am trying to produce 1000, 20mb files to see performance of Kafka.
我们的Apache kafka环境有1 - zk, 3 -服务器。每个服务器上的堆大小为1800 MB。我正在尝试生成1000个20mb的文件来查看Kafka的性能。
I am getting: [PDT] 2015-03-23 13:53:50 Selector [WARN] Error in I/O with host 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:724)
我正在获取:[PDT] 2015-03-23 13:53:50选择器[警告]在主机java.io的I/O中出错。com .com .com .com .com .com .com .com .com .com .com .
This error I am getting sometimes @ 997th message and sometimes @ 999th message. There is no pattern.
这个错误有时@ 997，有时@ 999。没有模式。
Thanks and appreciate your time!
谢谢您的宝贵时间!
1 个解决方案
#1
0
This has been solved here https://issues.apache.org/jira/browse/KAFKA-3205
这里已经解决了https://issues es.apache.org/jira/browse/kafka -3205
Try increasing the connections.max.idle.ms in the broker config (the brokers in kafka 0.9 have a default of 10 minutes)
试着增加connections.max.idle。代理配置中的ms (kafka 0.9中的代理默认为10分钟)
#1
0
This has been solved here https://issues.apache.org/jira/browse/KAFKA-3205
这里已经解决了https://issues es.apache.org/jira/browse/kafka -3205
Try increasing the connections.max.idle.ms in the broker config (the brokers in kafka 0.9 have a default of 10 minutes)
试着增加connections.max.idle。代理配置中的ms (kafka 0.9中的代理默认为10分钟)