验证Topic单Partition单副本生产消费性能

一、预置条件

1. 集群已经安装完成并正常运行；

2. 客户端软件已经正确安装到客户端节点上；

3. 已经在集群Manager平台上为测试任务添加了一个人机用户，属组为kafkaadmin，假设用户名为kafkatest，用户认证成功；

4. kafka集群中3个broker节点服务正常

二、测试步骤

1. 登录客户端，查看客户端配置信息，配置临时环境变量zklist，取值为server.properties中的zookeeper.connect

   
   

2. 配置临时环境变量brokerlist

   
   

3.  创建测试用topic

   
   

4. 生产性能测试

   参数说明： --topic 指定测试用的topic名称，--num-records 测试发送消息总条数 --throughput 最大消息吞吐量 --producer-props 通过键值对的形式指定属性

   测试结果说明：第2列表示平均吞吐量、第3列表示平均时延

   
   

5. 消费性能测试

   参数说明： --threads 指定线程数 --topic 测试topic --messages 读取消息条数 --group 指定消费者分组