1. 下載kafka ,并解壓kafka
下載
wget https://dlcdn.apache.org/kafka/3.9.0/kafka_2.13-3.9.0.tgz
解壓
tar -zxvf kafka_2.13-3.9.0.tgz
轉(zhuǎn)到bin 目錄
cd kafka_2.13-3.9.0/bin/
2.創(chuàng)建測試topic
kafka-topics.sh --bootstrap-server 127.0.0.1:9092 --create --topic test_topic --partitions 16 --replication-factor 3
3.壓測(注意topic)
./kafka-producer-perf-test.sh --topic test_topic --num-records 100000 --record-size 2048 --throughput=-1 --producer-props acks=all batch.size=524288 compression.type=zstd linger.ms=5 bootstrap.servers=127.0.0.1:9092
4. 返回
100000 records sent, 60168.471721 records/sec (117.52 MB/sec), 32.69 ms avg latency, 370.00 ms max latency, 29 ms 50th, 64 ms 95th, 98 ms 99th, 116 ms 99.9th.
最后編輯于 ：2024.12.23 19:31:24
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
