Kafka压测报告

一、测试目的

本测试旨在评估单台服务器上Kafka处理MQ消息的性能，通过进行写入和消费MQ消息的压力测试，来确定其是否满足项目需求。

二、测试范围及方法

2.1 测试范围概述

利用Kafka自带的测试脚本对写入和消费MQ消息性能进行压力测试，并评估其亿级消息处理能力。

2.2 性能测试场景设计

测试设计了不同数量级的消息写入和消费场景，对应的测试参数包括MQ消息数、每秒写入消息数和记录大小。

2.3 测试方法简要描述

通过服务器上的Kafka测试脚本，模拟不同数量级的消息写入和消费请求，测定处理能力，包括消息吞吐量和延迟时间。

三、测试环境

测试在包含Kafka(kafka_2.12-2.6.0)的单台服务器上进行，使用Kafka自带压测脚本作为测试工具。

四、测试结果

4.1 测试结果说明

关注Kafka写入消息的延迟时间和MQ消息处理的压力测试，验证消息处理能力。

4.2 测试结果

在写入MQ消息测试中，1w、10w、100w消息的95%延迟时间均小于800ms。消费MQ消息测试中，100w消息的每秒处理能力超过20w条。具体性能表现为每秒平均写入62.79MB数据，最大延迟694ms，消费100w条消息时每秒消费数据大小为259.9669M。

五、结果分析

单台服务器上Kafka处理5000条/秒的写入MQ消息性能基本满足需求，但有优化空间。消费MQ消息能力表现理想，单台服务器测试结果对评估集群服务满足实际应用需求具有参考价值。