步驟 5：產生和取用資料

產生和取用訊息

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

   $KAFKA_ROOT/bin/kafka-console-producer.sh --broker-list $BOOTSTRAP_SERVER --producer.config $KAFKA_ROOT/config/client.properties --topic MSKTutorialTopic

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

3. 保持與用戶端機器的連線開啟，然後開啟第二個並在新視窗中與該機器單獨連線。由於這是新的工作階段，請再次設定 KAFKA_ROOT和 BOOTSTRAP_SERVER環境變數。如需如何設定這些環境變數的資訊，請參閱 在用戶端機器上建立主題。

4. 使用用戶端機器的第二個連線字串執行下列命令，以建立主控台取用者。

   $KAFKA_ROOT/bin/kafka-console-consumer.sh --bootstrap-server $BOOTSTRAP_SERVER --consumer.config $KAFKA_ROOT/config/client.properties --topic MSKTutorialTopic --from-beginning

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

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