Skip to content

Commit

Permalink
add readme for the embedded consumer system test
Browse files Browse the repository at this point in the history
  • Loading branch information
Jun Rao committed May 2, 2011
1 parent 1dcdd7e commit efbad29
Show file tree
Hide file tree
Showing 2 changed files with 22 additions and 0 deletions.
11 changes: 11 additions & 0 deletions system_test/embedded_consumer/README
Original file line number Diff line number Diff line change
@@ -0,0 +1,11 @@
This test replicates messages from one kafka node to another using the embedded consumer. At the end, the messages
produced at the source kafka node should be identical to that at the target kafka node.

To run this test, do
bin/run-test.sh

The expected output is given in expected.out. There are 2 things to pay attention to:
1. The output should have a line "test passed".
2. The throughput from the producer should be around 90,000 Messages/sec on a typical machine.

This test may take 10 to 15 minutes to finish.
11 changes: 11 additions & 0 deletions system_test/embedded_consumer/expected.out
Original file line number Diff line number Diff line change
@@ -0,0 +1,11 @@
start the servers ...
start producing messages ...
Total Num Messages: 10000000 bytes: 1994374785 in 106.076 secs
Messages/sec: 94272.0314
MB/sec: 17.9304
[2011-05-02 11:50:29,022] INFO Disconnecting from localhost:9092 (kafka.producer.SyncProducer)
wait for consumer to finish consuming ...
test passed
bin/../../../bin/kafka-server-start.sh: line 11: 359 Terminated $(dirname $0)/kafka-run-class.sh kafka.Kafka $@
bin/../../../bin/zookeeper-server-start.sh: line 9: 357 Terminated $(dirname $0)/kafka-run-class.sh org.apache.zookeeper.server.quorum.QuorumPeerMain $@
bin/../../../bin/zookeeper-server-start.sh: line 9: 358 Terminated $(dirname $0)/kafka-run-class.sh org.apache.zookeeper.server.quorum.QuorumPeerMain $@

0 comments on commit efbad29

Please sign in to comment.