在 MSK Serverless 中產生和使用資料

產生和取用訊息

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. 執行下列命令，使用第二個用戶端機器連線建立主控台取用者。Replace (取代) 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. 在生產者視窗中輸入更多訊息，並觀看它們出現在取用者視窗中。