更新时间:2023-09-01 GMT+08:00
分享

测试环境

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

步骤一:购买Kafka实例

购买一个Kafka实例,参数信息如下,购买方法请参考购买实例

  • 区域:华北-北京四
  • 项目:华北-北京四
  • 可用区:可用区1
  • 实例名称:kafka-test
  • 企业项目:default
  • 版本:2.7
  • 代理规格:kafka.2u4g.cluster
  • 代理个数:3
  • 存储空间:超高I/O,200GB
  • 容量阈值策略:自动删除
  • 虚拟私有云:选择虚拟私有云,如果未创建,请参考准备实例依赖资源创建。
  • 安全组:选择安全组,安全组需要满足分布式消息服务Kafka版的要求,具体请参考准备实例依赖资源
  • 内网访问:开启“明文接入”
  • 公网访问:不开启
  • 更多配置:不开启“Smart Connect”和“Kafka自动创建Topic”

购买完成后,在实例详情页获取Kafka实例的地址。

步骤二:创建Topic

在购买的Kafka实例中,创建如下参数的3个Topic,具体步骤请参考创建Topic

  • Topic-01:3分区1副本,异步复制
  • Topic-02:3分区3副本,异步复制
  • Topic-03:3分区3副本,同步复制

步骤三:获取测试工具

获取Kafka命令行工具2.7.2版本

步骤四:购买客户端服务器

购买如下参数的2台ECS服务器,具体步骤请参考购买弹性云服务器

  • 区域、可用区、虚拟私有云、子网、安全组与Kafka实例保持一致,规格为4U8G,Linux系统的ECS。
  • 区域、虚拟私有云、子网、安全组与Kafka实例保持一致,“可用区”为“可用区2”,规格为4U8G,Linux系统的ECS。

购买完成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
分享:

    相关文档

    相关产品