本文為英文版的機器翻譯版本,如內容有任何歧義或不一致之處,概以英文版為準。
步驟 5:產生和取用資料
在開始使用 Amazon MSK的此步驟中,您會產生和使用資料。
產生和取用訊息
-
執行下列命令以啟動主控台生產者。
BootstrapServerString
將 取代為您在建立主題中取得的純文字連線字串。如需如何擷取此連線字串的指示,請參閱取得 Amazon MSK叢集的引導代理程式。<path-to-your-kafka-installation>
/bin/kafka-console-producer.sh --broker-listBootstrapServerString
--producer.config client.properties --topicMSKTutorialTopic
-
輸入您想要的任何訊息,然後按 Enter 鍵。重複此步驟兩次或三次。每次輸入一行,然後按 Enter,該行會作為單獨訊息傳送到您的 Apache Kafka 叢集中。
-
保持與用戶端機器的連線開啟,然後開啟第二個並在新視窗中與該機器單獨連線。
-
在下列命令中,將 取代
BootstrapServerString
為您稍早儲存的純文字連線字串。然後,若要建立主控台取用者,請執行下列命令,將第二個連線連接至用戶端機器。<path-to-your-kafka-installation>
/bin/kafka-console-consumer.sh --bootstrap-serverBootstrapServerString
--consumer.config client.properties --topicMSKTutorialTopic
--from-beginning當您使用主控台生產者命令時,您會開始看到先前輸入的訊息。
-
在生產者視窗中輸入更多訊息,並觀看它們出現在取用者視窗中。
後續步驟
步驟 6:使用 Amazon CloudWatch 來檢視 Amazon MSK指標