ステップ 5: データを生成および消費する

メッセージを生成および消費するには

1. 次のコマンドを実行して、コンソールプロデューサーを起動します。

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

2. 必要なメッセージを入力して、Enter キーを押します。このステップを 2、3 回繰り返します。行を入力して [Enter] キーを押すたびに、その行は個別のメッセージとして Apache Kafka クラスターに送信されます。

3. クライアントマシンへの接続を開いたままにして、そのマシンへ 2 番目の別の接続を新しいウィンドウで開きます。これは新しいセッションであるため、 KAFKA_ROOTおよび BOOTSTRAP_SERVER環境変数を再度設定します。これらの環境変数を設定する方法については、「」を参照してくださいクライアントマシンでのトピックの作成。

4. クライアントマシンへの 2 番目の接続文字列を使用して次のコマンドを実行して、コンソールコンシューマーを作成します。

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

   コンソールプロデューサーコマンドを使用したときに、前に入力したメッセージの表示を開始する必要があります。

5. プロデューサーウィンドウにさらにメッセージを入力し、コンシューマーウィンドウに表示されるようにします。