You are viewing a plain text version of this content. The canonical link for it is here.

Posted to users@kafka.apache.org by Dillian Murphey <cr...@gmail.com> on 2015/01/28 17:36:34 UTC

WARN Error in I/O with NetworkReceive.readFrom(NetworkReceive.java

Running the performance test. What is the nature of this error??  I'm
running a very high end cluster on aws. Tried this even within the same
subnet on aws.

bin/kafka-run-class.sh org.apache.kafka.clients.tools.ProducerPerformance
topic9 50000000 100 -1 acks=1 bootstrap.servers=$IP:9092
buffer.memory=67108864 batch.size=8196



2015-01-28 16:32:22,178] WARN Error in I/O with /<IP ADDR>
(org.apache.kafka.common.network.Selector)
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)
65910 records sent, 13158.3 records/sec (1.25 MB/sec), 38525.9 ms avg
latency, 39478.0 max latency.

Thanks for any ideas

Re: WARN Error in I/O with NetworkReceive.readFrom(NetworkReceive.java

Posted by Jun Rao <ju...@confluent.io>.

Any error on the broker log?

Thanks,

Jun

On Wed, Jan 28, 2015 at 8:36 AM, Dillian Murphey <cr...@gmail.com>
wrote:

> Running the performance test. What is the nature of this error??  I'm
> running a very high end cluster on aws. Tried this even within the same
> subnet on aws.
>
> bin/kafka-run-class.sh org.apache.kafka.clients.tools.ProducerPerformance
> topic9 50000000 100 -1 acks=1 bootstrap.servers=$IP:9092
> buffer.memory=67108864 batch.size=8196
>
>
>
> 2015-01-28 16:32:22,178] WARN Error in I/O with /<IP ADDR>
> (org.apache.kafka.common.network.Selector)
> 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)
> 65910 records sent, 13158.3 records/sec (1.25 MB/sec), 38525.9 ms avg
> latency, 39478.0 max latency.
>
> Thanks for any ideas
>