![](https://csdnimg.cn/release/download_crawler_static/86279961/bg3.jpg)
51Testing 软件测试网 www.51testing.com
dn3:9092
# 设置 10 个线程数
[hadoop@dn1 ~]$ kafka-producer-perf-test-0.8.sh --messages 5000000
--topics test_producer_perf --threads 10 --broker-list dn1:9092,
dn2:9092, dn3:9092
# 设置 20 个线程数
[hadoop@dn1 ~]$ kafka-producer-perf-test-0.8.sh --messages 5000000
--topics test_producer_perf --threads 20 --broker-list dn1:9092,
dn2:9092, dn3:9092
# 设置 25 个线程数
[hadoop@dn1 ~]$ kafka-producer-perf-test-0.8.sh --messages 5000000
--topics test_producer_perf --threads 25 --broker-list dn1:9092,
dn2:9092, dn3:9092
# 设置 30 个线程数
[hadoop@dn1 ~]$ kafka-producer-perf-test-0.8.sh --messages 5000000
--topics test_producer_perf --threads 30 --broker-list dn1:9092,
dn2:9092, dn3:9092
3.1.1 测试结果
3.1.2 结论
向一个拥有 6 个分区、1 个副本的 Topic 中,发送 500 万条消息记录时,随着线程数的
增加,每秒发送的消息记录会逐渐增加。在线程数为 25 时,每秒发送的消息记录达到最
佳值,随后再增加线程数,每秒发送的消息记录数反而会减少。
3.2 分区数
(1)新建一个拥有 12 个分区、1 个副本的主题;
(2)新建一个拥有 24 个分区、1 个副本的主题;
(3)向拥有 12 个分区、1 个副本的主题中发送相同数量的消息记录,查看性能变化;
(4)向拥有 24 个分区、1 个副本的主题中发送相同数量的消息记录,查看性能变化。