Spring Cloud Stream Applications 2022.0.0

Spring Cloud Stream Applications は、Apache Kafka や RabbitMQ などのメッセージングミドルウェアを介して通信するスタンドアロンの実行可能アプリケーションです。

これらのアプリケーションは、Kubernetes、Docker、Cloud Foundry などのさまざまなランタイムプラットフォーム上で、またはラップトップ上でも独立して実行できます。

機能

• スタンドアロンの Spring Boot アプリケーションとして実行できる、すぐに使用可能なアプリケーション。

• アプリケーションのセットを Spring Cloud Data Flow のコヒーレントストリーミングデータパイプラインにアセンブルします。

• アプリケーションプロパティ、環境変数、YAML ファイルで設定パラメーターを上書きします。

利用可能なアプリケーション

利用可能なアプリケーションのリストはここで見つけることができます。

クイックスタート

ステップ 1-​ ここ (英語) から最新のタイムソースアプリケーションをダウンロードします (たとえば: 4.0.1-SNAPSHOT)

ステップ 2-​ ここ (英語) から最新のログシンクアプリケーションをダウンロードします (たとえば: 4.0.1-SNAPSHOT)

ステップ 3 - Kafka を開始

ステップ 4 - Kafka の ticktock トピックを指すタイムソースプロデューサーアプリケーションを起動します

java -jar time-source-kafka-***.jar --spring.cloud.stream.bindings.output.destination=ticktock

ステップ 5 - Kafka の ticktock トピックを指すログシンクコンシューマーアプリケーションを起動します

java -jar log-sink-kafka-***.jar --spring.cloud.stream.bindings.input.destination=ticktock --server.port=0

ステップ 6 - log-sink ログの ticktock 出力を確認します

ストリームアプリケーションと Spring Cloud Data Flow

Spring Cloud Data Flow のアプリの使用方法については、リファレンスガイドのアプリ登録 (英語) セクションを参照してください。

アプリの HTTP リポジトリの場所

次のリンクは、wget、curl などのツールを使用して個々のアプリケーションとメタデータをダウンロードする便利な方法です。これらのファイルを参照して、個々のアプリケーションリンクをコピーできます。

関連プロジェクト

• Spring Cloud Stream

• Spring Cloud Data Flow (英語)

• Spring Cloud Task [GitHub] (英語)