我有机会使用了 Spring Cloud Data Flow 的流和批处理。流在生产环境中运行良好。主要的流使用了 Debezium 将数据库的变更发送到 Soap 端点，或者提供了 Soap 端点写入数据库。事件通过 Kafka 发送。Spring Cloud Data Flow 还提供了一个应用程序来管理流和作业。 这些流是由数据源和数据接收器构建的，它们是独立的应用程序，通过 Kafka 发送的事件进行解耦。流 1 包含一个 Debezium 源，通过 Kafka 将数据库变更发送到数据接收器，数据接收器将事件转换为对应用程序的 Soap 请求。流 2 从应用程序接收 Soap 请求，并将事件发送到 Kafka。数据接收器接收事件并为该事件创建数据库条目。