分布式消息服务KAFKA版-测试Kafka实例TPS:测试环境

时间:2024-12-12 16:47:07

测试环境

进行TPS测试前,您需要先构建如下的测试环境:

  1. 购买如表1所示实例,购买步骤请参考购买Kafka实例
    表1 实例参数

    名称

    代理数量

    规格

    是否开启SASL

    磁盘类型

    kafka-01

    3

    kafka.2u4g.cluster

    超高I/O

    kafka-02

    3

    kafka.4u8g.cluster

    超高I/O

    kafka-03

    3

    kafka.8u16g.cluster

    超高I/O

    kafka-04

    3

    kafka.12u24g.cluster

    超高I/O

    kafka-05

    3

    kafka.16u32g.cluster

    超高I/O

    kafka-06

    3

    kafka.2u4g.cluster

    超高I/O

    kafka-07

    3

    kafka.4u8g.cluster

    超高I/O

    kafka-08

    3

    kafka.8u16g.cluster

    超高I/O

    kafka-09

    3

    kafka.12u24g.cluster

    超高I/O

    kafka-10

    3

    kafka.16u32g.cluster

    超高I/O

    kafka-11

    3

    kafka.2u4g.cluster

    高I/O

    kafka-12

    3

    kafka.4u8g.cluster

    高I/O

    kafka-13

    3

    kafka.8u16g.cluster

    高I/O

    kafka-14

    3

    kafka.12u24g.cluster

    高I/O

    kafka-15

    3

    kafka.16u32g.cluster

    高I/O

    购买完成后,在实例详情页获取Kafka实例的内网明文连接地址。

  2. 购买实例后,创建如表2所示Topic,创建步骤请参考创建Kafka Topic
    表2 Topic参数

    名称

    是否同步复制

    是否同步落盘

    副本数

    分区数

    topic-01

    3

    30

    topic-02

    3

    30

    topic-03

    3

    30

    topic-04

    3

    3

    topic-05

    3

    12

    topic-06

    3

    100

  3. 获取测试工具。

    获取Kafka命令行工具2.7.2版本

  4. 购买客户端服务器。

    购买1台E CS 服务器(区域、可用区、虚拟私有云、子网、安全组与Kafka实例保持一致,Linux系统),具体步骤请参考购买弹性云服务器

    购买完成ECS后,需要在ECS中完成以下配置:

    • 安装Java JDK,并配置JAVA_HOME与PATH环境变量。
      export JAVA_HOME=/root/jdk1.8.0_231 
      export PATH=$JAVA_HOME/bin:$PATH
    • 下载Kafka命令行工具2.7.2版本,并解压。
      tar -zxf kafka_2.12-2.7.2.tgz
support.huaweicloud.com/usermanual-kafka/kafka-ug-0068.html