測試場景

• 測試場景一（實例是否開啟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）