kafka性能测试

kafka性能测试,第1张

kafka性能测试
测试时候,创建一个名字为test的topic。
然后执行命令
Kafka测试数据
bin/kafka-topics.sh --create  --bootstrap-server  172.29.17.28:8092 --replication-factor 3 --partitions 3 --topic test
命令是:
1.bin/kafka-producer-perf-test.sh 
2.bin/kafka-consumer-perf-test.sh



生产者测试设置值
单个消息大小:1000字节
限制每秒发送的最⼤的消息数:无限制
写入消息数分别为10w,100w,1000w
消息数(w)	吞吐量
(MB/秒)	平均时延(ms)	最大时延(ms)	50 % 的消息延时(ms)	95 % 的消息延时(ms)	99 % 的消息延时(ms)
10	101.24	292.25	371.00	294	351	356
100	438.87	52.79	327.00	15	213	286
1000	722.59	6.67	310.00	2	16	158
消费者设置测试值
⼀次请求消费的⼤⼩:1048576既为1M
消费的线程数:8
消费消息数分别为10w,100w,1000w
消息数
(w)	共消费数据(M)	每秒消费数据(M)	每秒消费消息数	消费耗时
(s)
10	0.0010	0.0003	0.2762	
100	820.1609	820.1599	860000.0000	1.000
1000	9308.3391	1094.8181	1148000.0000	8.50


欢迎分享,转载请注明来源:内存溢出

原文地址: http://outofmemory.cn/zaji/5717276.html

(0)
打赏 微信扫一扫 微信扫一扫 支付宝扫一扫 支付宝扫一扫
上一篇 2022-12-17
下一篇 2022-12-18

发表评论

登录后才能评论

评论列表(0条)

保存