1、首先了解下本次测试关注的几个参数：分区 + 副本、压缩方式、ACK、消息总数、消息大小、fetch-siza

2、

./kafka-producer-perf-test.sh --topic t9p3r --num-records 5000000 --record-size 1024 --throughput -1 --producer-props bootstrap.servers=192.168.1.xx:xxxx,192.168.1.xxx:xxxx,192.168.1.xx:xxxx acks=1

3、注意配置信息：
测试的 Topic 名称：t9p3r
消息总数：500W
单条消息大小：1024
ACK 的值：1（0、1、-1）

4、

./kafka-consumer-perf-test.sh --broker-list 192.168.1.xx:xxxx,192.168.1.xxx:xxxx,192.168.1.xx:xxxx --fetch-size 50000 --messages 2000000 --topic t3p3r

5、配置信息参考第三点

6、压缩方式配置：修改../config/producer.properties 的 compression.type(gzip/lz4/snappy，默认值 none)

7、a) 资源有限的情况下执行时关注服务端磁盘使用情况，及时清理

*附：测试报告*