| start the servers ... |
| start producing messages ... |
| wait for consumer to finish consuming ... |
| [2011-05-17 14:49:11,605] INFO Creating async producer for broker id = 2 at localhost:9091 (kafka.producer.ProducerPool) |
| [2011-05-17 14:49:11,606] INFO Creating async producer for broker id = 1 at localhost:9092 (kafka.producer.ProducerPool) |
| [2011-05-17 14:49:11,607] INFO Creating async producer for broker id = 3 at localhost:9090 (kafka.producer.ProducerPool) |
| thread 0: 400000 messages sent 3514012.1233 nMsg/sec 3.3453 MBs/sec |
| [2011-05-17 14:49:34,382] INFO Closing all async producers (kafka.producer.ProducerPool) |
| [2011-05-17 14:49:34,383] INFO Closed AsyncProducer (kafka.producer.async.AsyncProducer) |
| [2011-05-17 14:49:34,384] INFO Closed AsyncProducer (kafka.producer.async.AsyncProducer) |
| [2011-05-17 14:49:34,385] INFO Closed AsyncProducer (kafka.producer.async.AsyncProducer) |
| Total Num Messages: 400000 bytes: 79859641 in 22.93 secs |
| Messages/sec: 17444.3960 |
| MB/sec: 3.3214 |
| test passed |
| stopping the servers |
| bin/../../../bin/zookeeper-server-start.sh: line 9: 22584 Terminated $(dirname $0)/kafka-run-class.sh org.apache.zookeeper.server.quorum.QuorumPeerMain $@ |
| bin/../../../bin/zookeeper-server-start.sh: line 9: 22585 Terminated $(dirname $0)/kafka-run-class.sh org.apache.zookeeper.server.quorum.QuorumPeerMain $@ |
