Ich hatte die Gelegenheit, mit Spring Cloud Data Flow Streams und Batches zu arbeiten. Die Streams funktionieren in der Produktion und erbringen eine gute Leistung. Die Hauptstreams nutzten Debezium, um die Datenbankdeltas an Soap-Endpunkte zu senden oder stellten Soap-Endpunkte bereit, um in die Datenbank zu schreiben. Die Ereignisse wurden über Kafka gesendet. Spring Cloud Data Flow bietet auch eine Anwendung zur Verwaltung der Streams und Jobs. Die Streams werden mit einer Datenquelle und einer Datensenke erstellt, die separate Anwendungen sind und durch die über Kafka gesendeten Ereignisse entkoppelt werden. Stream 1 hat eine Debezium-Quelle und sendet die Datenbankdeltas über Kafka an die Senke, die das Ereignis in eine Soap-Anfrage an die Anwendung umwandelt. Stream 2 empfängt eine Soap-Anfrage von der Anwendung und sendet ein Ereignis an Kafka. Die Senke empfängt das Ereignis und erstellt die Datenbankeinträge für das Ereignis.