start the servers ... start producing 2000000 messages ... [2011-05-17 14:31:12,568] INFO Creating async producer for broker id = 0 at localhost:9092 (kafka.producer.ProducerPool) thread 0: 100000 messages sent 3272786.7779 nMsg/sec 3.1212 MBs/sec thread 0: 200000 messages sent 3685956.5057 nMsg/sec 3.5152 MBs/sec thread 0: 300000 messages sent 3717472.1190 nMsg/sec 3.5453 MBs/sec thread 0: 400000 messages sent 3730647.2673 nMsg/sec 3.5578 MBs/sec thread 0: 500000 messages sent 3730647.2673 nMsg/sec 3.5578 MBs/sec thread 0: 600000 messages sent 3722315.2801 nMsg/sec 3.5499 MBs/sec thread 0: 700000 messages sent 3718854.5928 nMsg/sec 3.5466 MBs/sec thread 0: 800000 messages sent 3714020.4271 nMsg/sec 3.5420 MBs/sec thread 0: 900000 messages sent 3713330.8578 nMsg/sec 3.5413 MBs/sec thread 0: 1000000 messages sent 3710575.1391 nMsg/sec 3.5387 MBs/sec thread 0: 1100000 messages sent 3711263.6853 nMsg/sec 3.5393 MBs/sec thread 0: 1200000 messages sent 3716090.6726 nMsg/sec 3.5439 MBs/sec thread 0: 1300000 messages sent 3709198.8131 nMsg/sec 3.5374 MBs/sec thread 0: 1400000 messages sent 3705762.4606 nMsg/sec 3.5341 MBs/sec thread 0: 1500000 messages sent 3701647.2330 nMsg/sec 3.5302 MBs/sec thread 0: 1600000 messages sent 3696174.4594 nMsg/sec 3.5249 MBs/sec thread 0: 1700000 messages sent 3703703.7037 nMsg/sec 3.5321 MBs/sec thread 0: 1800000 messages sent 3703017.9596 nMsg/sec 3.5315 MBs/sec thread 0: 1900000 messages sent 3700277.5208 nMsg/sec 3.5289 MBs/sec thread 0: 2000000 messages sent 3702332.4695 nMsg/sec 3.5308 MBs/sec [2011-05-17 14:33:01,102] INFO Closing all async producers (kafka.producer.ProducerPool) [2011-05-17 14:33:01,103] INFO Closed AsyncProducer (kafka.producer.async.AsyncProducer) Total Num Messages: 2000000 bytes: 400000000 in 108.678 secs Messages/sec: 18402.9886 MB/sec: 3.5101 wait for data to be persisted test passed bin/../../../bin/kafka-server-start.sh: line 11: 21110 Terminated $(dirname $0)/kafka-run-class.sh kafka.Kafka $@ bin/../../../bin/zookeeper-server-start.sh: line 9: 21109 Terminated $(dirname $0)/kafka-run-class.sh org.apache.zookeeper.server.quorum.QuorumPeerMain $@