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) 资源有限的情况下执行时关注服务端磁盘使用情况,及时清理
*附:测试报告*