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

手順

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

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

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

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

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

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