测试场景

• 测试场景一（实例是否开启SASL）：相同的Topic，实例分为开启SASL和未开启SASL
• 测试场景二（同步/异步复制）：相同的实例，不同复制机制的Topic
• 测试场景三（不同磁盘类型）：相同的Topic，不同磁盘类型的实例
• 测试场景四（不同分区数）：相同的实例，不同分区数的Topic

测试环境

步骤一：购买实例

步骤二：创建Topic

步骤三：获取测试工具

点击获取命令行工具kafka_2.13-2.8.2.tgz。

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

购买3台ECS服务器（资源池、可用区、虚拟私有云、子网、安全组与Kafka实例保持一致，带宽要大于等于Kafka实例带宽）

购买完成后需要进行如下操作：

• 安装JDK

  yum install -y java-1.8.0-openjdk-devel.x86_64
  

• 下载Kafka命令行工具并解压

  tar -zxvf kafka_2.13-2.8.2.tar.gz
  

步骤五：测试命令

./kafka-producer-perf-test.sh --producer-props bootstrap.servers=${连接地址} acks=1 batch.size=16384 --topic ${Topic名称} --num-records 5000000 --record-size 1024 --throughput -1 --producer.config ../config/producer.properties

• bootstrap.servers：购买Kafka实例后，获取的Kafka实例的地址。
• acks：消息主从同步策略，acks=1表示异步复制消息，acks=-1表示同步复制消息。
• batch.size：每次批量发送消息的大小（单位为字节）。
• topic：创建Topic中设置的Topic名称。
• num-records：总共需要发送的消息数。
• record-size：每条消息的大小。
• throughput：每秒发送的消息数，-1表示不作限制。

测试结果

测试场景一（实例是否开启SASL）：相同的Topic（30分区，3副本，异步复制）

测试场景二（同步/异步复制）：相同的实例（超高I/O、3个节点、不使用SASL）

测试场景三（不同磁盘类型）：相同的Topic（30分区，3副本，异步复制）

测试场景四（不同分区数）：相同的实例（超高I/O、3个节点、不使用SASL）