第14章 Kafka クラスターへのクライアントアクセスの設定

手順

1. Kafka プロデューサーをデプロイします。

   oc run kafka-producer -ti --image=registry.redhat.io/amq-streams/kafka-37-rhel9:2.7.0 --rm=true --restart=Never -- bin/kafka-console-producer.sh --bootstrap-server cluster-name-kafka-bootstrap:9092 --topic my-topic

   Copy to Clipboard
2. プロデューサーが稼働しているコンソールにメッセージを入力します。
3. Enter を押してメッセージを送信します。

4. Kafka コンシューマーをデプロイします。

   oc run kafka-consumer -ti --image=registry.redhat.io/amq-streams/kafka-37-rhel9:2.7.0 --rm=true --restart=Never -- bin/kafka-console-consumer.sh --bootstrap-server cluster-name-kafka-bootstrap:9092 --topic my-topic --from-beginning

   Copy to Clipboard
5. コンシューマーコンソールに受信メッセージが表示されることを確認します。