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

手順

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

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

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

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

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

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