Red Hat Summit Red Hat Summitサポートコンソール開発者トライアルの開始お問い合わせ

5.15. Apache Kafka reactive サンプルの仕組み

このサンプルアプリケーションは、Apache Kafka を使用して実装された Publisher-Subscriber メッセージストリーミングパターンに基づいています。アプリケーションで設定されるコンポーネントは、以下のとおりです。

  • ログメッセージプロデューサーおよびコンシューマーをインスタンス化する KafkaExampleApplication クラス
  • Spring Boot HTTP Starter によって設定され、提供される WebFlux HTTP コントローラー。コントローラーは、メッセージの公開および読み取りに使用される残りのリソースを提供します。
  • プロデューサーが Kafka の log トピックにメッセージを公開する方法を定義する KafkaLogger クラス。
  • Kafka の log トピックからサンプルアプリケーションが受け取るメッセージを表示する KafkaLog クラス。

メッセージを公開します。

  1. ログメッセージをペイロードとして使用して、サンプルアプリケーションに対して HTTP POST 要求を実行します。
  2. HTTP コントローラーはメッセージを公開するのに使用される REST エンドポイントにルーティングし、そのメッセージをロガーインスタンスに渡します。
  3. HTTP コントローラーは、受け取ったメッセージを Kafka の log トピックに公開します。
  4. KafkaLog インスタンスは、Kafka トピックからログメッセージを受け取ります。

メッセージの読み取り:

  1. HTTP GET リクエストをサンプルアプリケーション URL に送信します。
  2. コントローラーは KafkaLog インスタンスからメッセージを取得し、HTTP 応答のボディーとして返します。
トップに戻る
Red Hat logoGithubredditYoutubeTwitter

詳細情報

試用、購入および販売

コミュニティー

Red Hat ドキュメントについて

Red Hat をお使いのお客様が、信頼できるコンテンツが含まれている製品やサービスを活用することで、イノベーションを行い、目標を達成できるようにします。 最新の更新を見る.

多様性を受け入れるオープンソースの強化

Red Hat では、コード、ドキュメント、Web プロパティーにおける配慮に欠ける用語の置き換えに取り組んでいます。このような変更は、段階的に実施される予定です。詳細情報: Red Hat ブログ.

会社概要

Red Hat は、企業がコアとなるデータセンターからネットワークエッジに至るまで、各種プラットフォームや環境全体で作業を簡素化できるように、強化されたソリューションを提供しています。

Theme

© 2025 Red Hat