本文介绍使用开源 Kafka 工具,对 Kafka 进行生产和消费压力测试的相关内容。
Kafka Producer 和 Consumer 的性能测试均可使用 Kafka 客户端自带的开源脚本,主要输出每秒发送消息数(records/second)和每秒发送消息量(MB/second)两项指标。
本文使用开源的 Kafka 2.2.2 版本工具包为例,下载地址为:https://archive.apache.org/dist/kafka/2.2.2/kafka_2.11-2.2.2.tgz
下载并解压后,您需要了解以下信息:
/bin/kafka-producer-perf-test.sh
/bin/kafka-consumer-perf-test.sh
/config/producer.properties
/config/consumer.properties
Kafka 实例提供默认接入点和 SASL 接入点,请按需选择执行压力测试的方式。