文章目录
- 1.生产者压力测试kafka-producer-perf-test.sh
- 2.消费者压力测试kafka-consumer-perf-test.sh
- More
日常运维 、问题排查 怎么能够少了滴滴开源的
滴滴开源LogiKM一站式Kafka监控与管控平台
1.生产者压力测试kafka-producer-perf-test.sh
1. 发送1024条消息--num-records 100
并且每条消息大小为1KB--record-size 1024
最大吞吐量每秒10000条--throughput 100
sh bin/kafka-producer-perf-test.sh --topic test_create_topic4 --num-records 100 --throughput 100000 --producer-props bootstrap.servers=localhost:9092 --record-size 1024
你可以通过LogIKM查看分区是否增加了对应的数据大小
从LogIKM 可以看到发送了1024条消息; 并且总数据量=1M; 1024条*1024byte = 1M;
2. 用指定消息文件--payload-file
发送100条消息最大吞吐量每秒100条--throughput 100
先配置好消息文件
batchmessage.txt
然后执行命令
发送的消息会从
batchmessage.txt
里面随机选择; 注意这里我们没有用参数--payload-delimeter
指定分隔符,默认分隔符是\n换行;bin/kafka-producer-perf-test.sh --topic test_create_topic4 --num-records 1024 --throughput 100 --producer-props bootstrap.servers=localhost:9090 --payload-file config/batchmessage.txt
- 验证消息,可以通过 LogIKM 查看发送的消息
相关可选参数
参数 | 描述 | 例子 |
| 指定消费的topic | |
| 发送多少条消息 | |
| 每秒消息最大吞吐量 | |
| 生产者配置, k1=v1,k2=v2 | |
| 生产者配置文件 | |
| 在test结束的时候打印监控信息,默认false | |
| 指定事务 ID,测试并发事务的性能时需要,只有在 --transaction-duration-ms > 0 时生效,默认值为 performance-producer-default-transactional-id | |
| 指定事务持续的最长时间,超过这段时间后就会调用 commitTransaction 来提交事务,只有指定了 > 0 的值才会开启事务,默认值为 0 | |
| 一条消息的大小byte; 和 --payload-file 两个中必须指定一个,但不能同时指定 | |
| 指定消息的来源文件,只支持 UTF-8 编码的文本文件,文件的消息分隔符通过 | |
| 如果通过 |
2.消费者压力测试kafka-consumer-perf-test.sh
消费100条消息--messages 100
sh bin/kafka-consumer-perf-test.sh -topic test_create_topic4 --bootstrap-server localhost:9090 --messages 100
相关可选参数
参数 | 描述 | 例子 |
| ||
| 消费者配置文件 | |
| 结果打印出来的时间格式化 | 默认:yyyy-MM-dd HH:mm:ss:SSS |
| 单次请求获取数据的大小 | 默认1048576 |
| 指定消费的topic | |
| ||
| 消费组ID | |
| 如果设置了,则不打印header信息 | |
| 需要消费的数量 | |
| feth 数据的线程数( | 默认:1 |
| 结束的时候打印监控数据 | |
| 如果设置,则按照 | |
| 消费线程数;( | 默认 10 |
| 打印进度信息的时间间隔(以毫秒为单位) |
More
Kafka专栏持续更新中…(源码、原理、实战、运维、视频、面试视频)
【kafka运维】Kafka全网最全最详细运维命令合集(精品强烈建议收藏!!!)_石臻臻的杂货铺-CSDN博客
【kafka实战】分区重分配可能出现的问题和排查问题思路(生产环境实战,干货!!!非常干!!!建议收藏)
【kafka异常】kafka 常见异常处理方案(持续更新! 建议收藏)
【kafka运维】分区从分配、数据迁移、副本扩缩容 (附教学视频)
【kafka源码】ReassignPartitionsCommand源码分析(副本扩缩、数据迁移、副本重分配、副本跨路径迁移
【kafka】点击更多…