步驟 5：產生和取用資料 - Amazon Managed Streaming for Apache Kafka

本文為英文版的機器翻譯版本，如內容有任何歧義或不一致之處，概以英文版為準。

步驟 5：產生和取用資料

在此步驟中，您會使用在上一個步驟建立的主題來產生和取用資料。

產生和取用訊息

  1. 執行下列命令以建立主控台生產者。

    <path-to-your-kafka-installation>/bin/kafka-console-producer.sh --broker-list $BS --producer.config client.properties --topic msk-serverless-tutorial

  2. 輸入您想要的任何訊息，然後按 Enter 鍵。重複此步驟兩次或三次。每次輸入一行，然後按 Enter 鍵，該行會作為獨立訊息傳送至您的叢集。

  3. 保持與用戶端機器的連線開啟，然後開啟第二個並在新視窗中與該機器單獨連線。

  4. 執行下列命令，使用第二個用戶端機器連線建立主控台取用者。使用建立叢集之後儲存的引導伺服器字串取代 my-endpoint。

    <path-to-your-kafka-installation>/bin/kafka-console-consumer.sh --bootstrap-server my-endpoint --consumer.config client.properties --topic msk-serverless-tutorial --from-beginning

    當您使用主控台生產者命令時，您會開始看到先前輸入的訊息。

  5. 在生產者視窗中輸入更多訊息，並觀看它們出現在取用者視窗中。

後續步驟

步驟 6：刪除資源