2.6. トピックからのメッセージの送受信
クラスター外部のメッセージを my-topic から送受信すると、AMQ Streams インストールをテストできます。
ターミナルを使用して、ローカルマシンで Kafka プロデューサーおよびコンシューマーを実行します。
前提条件
- AMQ Streams が OpenShift クラスターにインストールされていることを確認します。
- メッセージを送受信するには、Zookeeper および Kafka が稼働している必要があります。
- クラスターにアクセスするためにクラスター CA 証明書 が必要です。
- AMQ Streams のダウンロードサイト から最新バージョンの Red Hat AMQ Stremas アーカイブにアクセスできる必要があります。
手順
AMQ Streams のダウンロードサイト から最新バージョンの AMQ Stremas アーカイブ (
amq-streams-x.y.z-bin.zip) をダウンロードします。ファイルを任意の場所で展開します。
ターミナルを開き、トピック
my-topicと TLS の認証プロパティーを使用して Kafka コンソールプロデューサーを起動します。bin/kafka-console-producer.sh --broker-list ROUTE-ADDRESS:443 --producer-property security.protocol=SSL --producer-property ssl.truststore.password=password --producer-property ssl.truststore.location=./client.truststore.jks --topic my-topic- プロデューサーが実行しているコンソールにメッセージを入力します。
- Enter を押してメッセージを送信します。
新しいターミナルタブまたはウィンドウを開き、Kafka コンソールコンシューマーを起動してメッセージを受信します。
bin/kafka-console-consumer.sh --bootstrap-server ROUTE-ADDRESS:443 --consumer-property security.protocol=SSL --consumer-property ssl.truststore.password=password --consumer-property ssl.truststore.location=./client.truststore.jks --topic my-topic --from-beginning- コンシューマーコンソールに受信メッセージが表示されることを確認します。
- Crtl+C を押して、Kafka コンソールプロデューサーとコンシューマーを終了します。
