bash-4.4# $KAFKA_HOME/bin/kafka-consumer-perf-test.sh --version
2.6.0 (Commit:62abe01bee039651)

kafka-consumer-perf-test.sh的性能测试

作为一个消费者，可以与后面提到的kafka-producer-perf-test.sh进行组合或者使用其他方式进行生产。以下是使用–messages=10参数，一旦消费了10个消息就结束（或者超过了时间限制）。

$KAFKA_HOME/bin/kafka-consumer-perf-test.sh  --bootstrap-server localhost:9092 --topic=perftest --messages=10

完成后会显示摘要。

start.time, end.time, data.consumed.in.MB, MB.sec, data.consumed.in.nMsg, nMsg.sec, rebalance.time.ms, fetch.time.ms, fetch.MB.sec, fetch.nMsg.sec
2021-01-17 13:10:46:392, 2021-01-17 13:10:46:777, 0.0000, 0.0001, 24, 62.3377, 1610889046729, -1610889046344, -0.0000, -0.0000

kafka生产者性能测试脚本

–num-records 10 レコード数

–throughput 1 秒間produce数（たぶん。マニュアル読んでない）。

–record-size 10 各レコードのサイズ。10だとSSXVNJHPDQみたいのをproduceする。

bash-4.4# $KAFKA_HOME/bin/kafka-producer-perf-test.sh  --topic perftest --num-records 10 --throughput 1 --record-size 10 --producer-props bootstrap.servers=localhost:9092

结束后会显示摘要。

7 records sent, 1.3 records/sec (0.00 MB/sec), 54.3 ms avg latency, 295.0 ms max latency.
10 records sent, 1.073192 records/sec (0.00 MB/sec), 41.30 ms avg latency, 295.00 ms max latency, 13 ms 50th, 295 ms 95th, 295 ms 99th, 295 ms 99.9th.