Erstellen und Bereitstellen Ihrer ersten Cloudflow-Anwendung

Cloudflow ist ein relativ neues Framework, mit dem Sie verteilte Streaming-Anwendungen erstellen und auf Kubernetes bereitstellen können. Seine leistungsstarken Abstraktionen ermöglichen es Ihnen, Ihre Anwendung ganz einfach in unabhängige Streamverarbeitungskomponenten, sogenannte Streamlets, aufzuteilen. Streamlets können mit verschiedenen Laufzeiten wie Akka Streams und Flink entwickelt werden. Ein Streamlet kann einen oder mehrere Eingabeströme, Inlets, und einen oder mehrere Ausgabeströme, Outlets, haben. Sie stellen Ihre Anwendung als Ganzes bereit, während Cloudflow die Streamlets einzeln bereitstellt. Cloudflow sorgt dafür, dass die Daten zwischen den Inlets und Outlets Ihrer Streamlets zur Laufzeit über Kafka fließen, entsprechend Ihren Avro-Schemata und Ihrer Pipeline-Definition, die als Blueprint bezeichnet wird.

In diesem Beitrag werden wir eine einfache Anwendung mit dem Cloudflow-Framework und Akka Streams erstellen. Wir beginnen mit einem einfachen SBT-Projekt, um eine Stream-Verarbeitungspipeline einzurichten, sie lokal auszuführen und sie schließlich mit [mehr...]