Kafka: The Definitive Guide, 2. Auflage

Kapitel 5. Apache Kafka programmatisch verwalten

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

Es gibt viele CLI- und GUI-Tools für die Verwaltung von Kafka (wir werden sie in Kapitel 9 besprechen), aber es gibt auch Fälle, in denen du einige administrative Befehle aus deiner Client-Anwendung heraus ausführen möchtest. Ein besonders häufiger Anwendungsfall ist das Erstellen neuer Topics auf der Grundlage von Benutzereingaben oder Daten: Internet of Things (IoT)-Anwendungen empfangen oft Ereignisse von Benutzergeräten und schreiben Ereignisse in Themen, die auf dem Gerätetyp basieren. Wenn der Hersteller einen neuen Gerätetyp herstellt, musst du dich entweder über einen Prozess daran erinnern, auch ein Topic zu erstellen, oder die Anwendung kann dynamisch ein neues Topic erstellen, wenn sie Ereignisse mit einem nicht erkannten Gerätetyp erhält. Die zweite Alternative hat zwar Nachteile, aber die Vermeidung der Abhängigkeit von einem zusätzlichen Prozess zur Erstellung von Themen ist in den richtigen Szenarien eine attraktive Funktion.

Apache Kafka hat in Version 0.11 den AdminClient hinzugefügt, um eine programmatische API für administrative Funktionen bereitzustellen, die zuvor über die Kommandozeile ausgeführt wurden: Auflisten, Erstellen und Löschen von Topics, Beschreiben des Clusters, Verwalten von ACLs und Ändern der Konfiguration.

Hier ist ein Beispiel. Deine Anwendung wird Ereignisse ...