本文為英文版的機器翻譯版本,如內容有任何歧義或不一致之處,概以英文版為準。
在此步驟中,您會將資料傳送至先前建立的 Apache Kafka 主題,然後在目的地 S3 儲存貯體中尋找同一項資料。
傳送資料至 MSK 叢集
-
在用戶端執行個體上安裝 Apache Kafka 的
bin
資料夾中,建立一個名為client.properties
且具有以下內容的文字檔案。security.protocol=PLAINTEXT
-
執行下列命令以建立主控台生產者。使用您在執行先前命令時所取得的值來取代
BootstrapBrokerString
。<path-to-your-kafka-installation>
/bin/kafka-console-producer.sh --broker-listBootstrapBrokerString
--producer.config client.properties --topic mkc-tutorial-topic -
輸入您想要的任何訊息,然後按 Enter 鍵。重複此步驟兩次或三次。每次輸入一行,然後按 Enter,該行會作為單獨訊息傳送到您的 Apache Kafka 叢集中。
在目的地 Amazon S3 儲存貯體中查看,尋找您在上一個步驟中傳送的訊息。