翻訳は機械翻訳により提供されています。提供された翻訳内容と英語版の間で齟齬、不一致または矛盾がある場合、英語版が優先します。
ステップ 5: データを生成および消費する
このステップでは、前のステップで作成したトピックを使用してデータを生成および使用します。
メッセージを生成および消費するには
-
次のコマンドを実行して、コンソールプロデューサーを作成します。
<path-to-your-kafka-installation>
/bin/kafka-console-producer.sh --broker-list $BS --producer.config client.properties --topic msk-serverless-tutorial -
必要なメッセージを入力して、Enter キーを押します。このステップを 2、3 回繰り返します。行を入力して Enter キーを押すたびに、その行は個別のメッセージとしてクラスターに送信されます。
-
クライアントマシンへの接続を開いたままにして、そのマシンへ 2 番目の別の接続を新しいウィンドウで開きます。
-
クライアントマシンへの 2 回目の接続を使用して、以下のコマンドでコンソールコンシューマーを作成します。
my-endpoint
を、クラスターの作成後に保存したブートストラップサーバー文字列に置き換えます。<path-to-your-kafka-installation>
/bin/kafka-console-consumer.sh --bootstrap-servermy-endpoint
--consumer.config client.properties --topic msk-serverless-tutorial --from-beginningコンソール プロデューサーコマンドを使用したときに、以前に入力したメッセージが表示され始めます。
-
プロデューサーウィンドウにさらにメッセージを入力し、コンシューマーウィンドウに表示されるようにします。
次のステップ