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

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

步驟 5:產生和取用資料

開始使用 Amazon MSK的此步驟中,您會產生和使用資料。

產生和取用訊息
  1. 執行下列命令以啟動主控台生產者。BootstrapServerString 將 取代為您在建立主題中取得的純文字連線字串。如需如何擷取此連線字串的指示,請參閱取得 Amazon MSK叢集的引導代理程式。

    <path-to-your-kafka-installation>/bin/kafka-console-producer.sh --broker-list BootstrapServerString --producer.config client.properties --topic MSKTutorialTopic
  2. 輸入您想要的任何訊息,然後按 Enter 鍵。重複此步驟兩次或三次。每次輸入一行,然後按 Enter,該行會作為單獨訊息傳送到您的 Apache Kafka 叢集中。

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

  4. 在下列命令中,將 取代BootstrapServerString為您稍早儲存的純文字連線字串。然後,若要建立主控台取用者,請執行下列命令,將第二個連線連接至用戶端機器。

    <path-to-your-kafka-installation>/bin/kafka-console-consumer.sh --bootstrap-server BootstrapServerString --consumer.config client.properties --topic MSKTutorialTopic --from-beginning

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

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

後續步驟

步驟 6:使用 Amazon CloudWatch 來檢視 Amazon MSK指標