| 关键参数 | --messages、--group、--show-detailed-stats、--reporting-interval |
|---|---|
| 输出 | 消费条数、MB/sec、耗时 |
| 注意 | 会创建并提交消费组位移,勿复用业务组名 |
消费压测示例
消费压测示例
kafka-consumer-perf-test.sh --bootstrap-server kafka1:9092 \
--topic perf-orders --messages 1000000 \
--group perf-consumer-20261012 \
--show-detailed-stats --reporting-interval 5000消费端受分区数、fetch 参数与下游处理能力共同影响,单测拉取上限时要绕开业务处理逻辑。