测试时候,创建一个名字为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
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)