-
Notifications
You must be signed in to change notification settings - Fork 0
/
README
20 lines (13 loc) · 846 Bytes
/
README
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
An example program to play around with kafka-rust:
https://github.com/spicavigo/kafka-rust
Usage:
# monchan will print some timing information on debug level
$ export RUST_LOG=monchan=debug
# produce 100k small messages (to each available topic)
$ ./target/release/monchan --brokers 'localhost:9092' produce
# produce 100k small messages to each of the specified topics only
$ ./target/release/monchan --brokers 'localhost:9092' --topics 'my-topic-1,my-topic-2' produce
# consume a topic as fast as possible
$ ./target/releease/monchan --brokers 'localhost:9092' --topics 'my-topic-1' consume
# run a produce/consume test against a given topic
./target/release/monchan --compression=snappy --produce-msgs-per-topic 100 --produce-bytes-per-msg 10 --topics my-test-topic produce-consume-integration