Any error on the broker log? Thanks,
Jun On Wed, Jan 28, 2015 at 8:36 AM, Dillian Murphey <crackshotm...@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 >