測試 Amazon MSK TLS 加密

若要測試 TLS 加密

1. 依照 步驟 3：建立用戶端機器 中的指引建立用戶端機器。

2. 在用戶端機器上安裝 Apache Kafka。

3. 在此範例中，我們使用 JVM 信任存放區與 MSK 叢集通話。若要這樣做，請先在用戶端機器上建立名為 /tmp 的資料夾。然後，前往 Apache Kafka 安裝的 bin 資料夾，並執行以下命令。(您的 JVM 路徑可能不同。)

   cp /usr/lib/jvm/java-1.8.0-openjdk-1.8.0.201.b09-0.amzn2.x86_64/jre/lib/security/cacerts /tmp/kafka.client.truststore.jks

4. 同時仍然在用戶端機器上的 Apache Kafka 安裝的 bin 資料夾中，建立一個名為 client.properties 且具有以下內容的文字檔案。

   security.protocol=SSL
   ssl.truststore.location=/tmp/kafka.client.truststore.jks

5. 在 AWS CLI 已安裝 的機器上執行下列命令，以叢集的 ARN 取代 clusterARN。

   aws kafka get-bootstrap-brokers --cluster-arn clusterARN

   成功的結果看起來如下。儲存此結果，因為您下一個步驟需要它。

   {
       "BootstrapBrokerStringTls": "a-1.example.g7oein.c2.kafka.us-east-1.amazonaws.com:0123,a-3.example.g7oein.c2.kafka.us-east-1.amazonaws.com:0123,a-2.example.g7oein.c2.kafka.us-east-1.amazonaws.com:0123"
   }

6. 執行下列命令，將 BootstrapBrokerStringTls 取代為您在上一個步驟中取得的其中一個代理程式端點。

   <path-to-your-kafka-installation>/bin/kafka-console-producer.sh --broker-list BootstrapBrokerStringTls --producer.config client.properties --topic TLSTestTopic

7. 開啟新的命令視窗並連線至相同的用戶端機器。然後，執行下列命令來建立主控台取用者。

   <path-to-your-kafka-installation>/bin/kafka-console-consumer.sh --bootstrap-server BootstrapBrokerStringTls --consumer.config client.properties --topic TLSTestTopic

8. 在生產者視窗中，輸入文字訊息後方跟著換行符號，然後在取用者視窗中尋找相同的訊息。Amazon MSK 會在傳輸中加密此訊息。