Kafka Streams und ksqlDB beherrschen

Kapitel 7. Prozessor-API

Diese Arbeit wurde mithilfe von KI übersetzt. Wir freuen uns über dein Feedback und deine Kommentare: [e-mail]

Vor ein paar Kapiteln haben wir uns auf den Weg gemacht, um Kafka Streams kennenzulernen. Wir haben mit der High-Level-DSL von Kafka Streams begonnen, die es uns ermöglicht, Stream-Processing-Anwendungen mit einer funktionalen und flüssigen Schnittstelle zu erstellen. Dazu müssen wir die in der Bibliothek integrierten Operatoren (z. B. filter, flatMap, groupBy, usw.) und Abstraktionen (KStream, KTable, GlobalKTable) nutzen, um Streaming-Funktionen zusammenzustellen und zu verketten.

In diesem Kapitel werden wir eine API auf niedrigerer Ebene untersuchen, die in Kafka Streams verfügbar ist: die Processor API (manchmal auch PAPI genannt). Die Processor API hat weniger Abstraktionen als die High-Level-DSL und verwendet einen imperativen Programmierstil. Der Code ist zwar in der Regel ausführlicher, aber auch leistungsfähiger und gibt uns die Möglichkeit, Folgendes genau zu steuern: wie Daten durch unsere Topologien fließen, wie Stream-Prozessoren zueinander in Beziehung stehen, wie der Status erstellt und aufrechterhalten wird und sogar das Timing bestimmter Operationen.

Einige der Fragen, die wir in diesem Kapitel beantworten werden, sind:

• Wann solltest du die Prozessor-API verwenden?

• Wie fügst du mit der Prozessor-API Quell-, Senken- und Stream-Prozessoren hinzu?

• Wie kannst du periodische Funktionen planen?

• Ist es ...