Spring Cloud Data Flow のストリームとバッチを扱う機会がありました。ストリームは本番環境で稼働しており、良好なパフォーマンスを発揮しています。主なストリームでは、Debezium を使用してデータベースの差分を Soap エンドポイントに送信したり、Soap エンドポイントを提供してデータベースに書き込んだりしていました。イベントは Kafka 経由で送信されました。Spring Cloud Data Flow は、ストリームとジョブを管理するためのアプリケーションも提供しています。 ストリームは、データソースとデータシンクで構築されており、これらは別々のアプリケーションであり、Kafka 経由で送信されるイベントによって疎結合されています。ストリーム 1 は Debezium ソースを持ち、データベースの差分を Kafka 経由でシンクに送信します。シンクはイベントを変換してアプリケーションへの SOAP リクエストを作成します。ストリーム 2 はアプリケーションから SOAP リクエストを受信し、Kafka にイベントを送信します。シンクはイベントを受信し、イベントのデータベースエントリを作成します。