Zum Inhalt springen

Apache Kafka Nachrichten abrufen-Aktivität in Jitterbit Studio

Einführung

Eine Apache Kafka Nachrichten abrufen-Aktivität, die ihre Apache Kafka-Verbindung verwendet, ruft Datenströme von einem Thema in einem Apache Kafka-Cluster ab und ist dazu gedacht, als Quelle für die Bereitstellung von Daten in einer Operation verwendet zu werden.

Erstellen einer Apache Kafka Nachrichten abrufen-Aktivität

Eine Instanz einer Apache Kafka Nachrichten abrufen-Aktivität wird aus einer Apache Kafka-Verbindung unter Verwendung des Aktivitätstyps Nachrichten abrufen erstellt.

Um eine Instanz einer Aktivität zu erstellen, ziehen Sie den Aktivitätstyp auf die Entwurfsfläche oder kopieren Sie den Aktivitätstyp und fügen Sie ihn auf der Entwurfsfläche ein. Weitere Informationen finden Sie unter Erstellen einer Aktivitäts- oder Toolinstanz in Komponentenwiederverwendung.

Eine vorhandene Apache Kafka Nachrichten abrufen-Aktivität kann von diesen Orten aus bearbeitet werden:

Konfigurieren einer Apache Kafka Nachrichten abrufen-Aktivität

Befolgen Sie diese Schritte, um eine Apache Kafka Nachrichten abrufen-Aktivität zu konfigurieren:

Schritt 1: Geben Sie einen Namen ein

In diesem Schritt geben Sie einen Namen für die Aktivität ein. Jedes Benutzeroberflächenelement dieses Schrittes wird im Folgenden beschrieben.

  • Endpoint-Menü: Wenn Sie mehrere Endpunkte des gleichen Verbindungstyps konfiguriert haben, wird ein Menü oben auf dem Bildschirm angezeigt, das den aktuellen Endpunktnamen anzeigt. Klicken Sie auf das Menü, um zu einem anderen Endpunkt zu wechseln. Weitere Informationen finden Sie unter Ändern des zugewiesenen Endpunkts in Konfigurationsbildschirmen.

    • Endpunkt bearbeiten: Wird angezeigt, wenn Sie über den aktuellen Endpunktnamen fahren. Klicken Sie, um die Verbindungsconfiguration des aktuell ausgewählten Endpunkts zu bearbeiten.

  • Name: Geben Sie einen Namen ein, um die Aktivität zu identifizieren. Der Name muss für jede Apache Kafka Get Messages-Aktivität eindeutig sein und darf keine Schrägstriche / oder Doppelpunkte : enthalten.

  • Speichern & Beenden: Wenn aktiviert, klicken Sie, um die Konfiguration für diesen Schritt zu speichern und die Aktivitätskonfiguration zu schließen.

  • Weiter: Klicken Sie, um die Konfiguration für diesen Schritt vorübergehend zu speichern und zum nächsten Schritt fortzufahren. Die Konfiguration wird nicht gespeichert, bis Sie die Schaltfläche Fertig im letzten Schritt klicken.

  • Änderungen verwerfen: Nachdem Sie Änderungen vorgenommen haben, klicken Sie, um die Konfiguration zu schließen, ohne die vorgenommenen Änderungen zu speichern. Eine Nachricht fordert Sie auf, zu bestätigen, dass Sie die Änderungen verwerfen möchten.

Schritt 2: Überprüfen Sie die Datenschemas

Alle Anforderungs- oder Antwortschemas, die vom Endpunkt generiert werden, werden angezeigt. Jedes Benutzeroberflächenelement dieses Schrittes wird im Folgenden beschrieben.

  • Datenschemas: Diese Datenschemas werden von angrenzenden Transformationen geerbt und während der Transformationszuordnung erneut angezeigt.

Der Apache Kafka-Connector verwendet die Apache Kafka Core API. Weitere Informationen zu den Schema-Knoten und -Feldern finden Sie in der API-Dokumentation.

Die Anforderungs- und Antwortdatenschemas bestehen aus diesen Knoten und Feldern:

Request Schema Node/Field Beschreibung
getMessagesRequest Knoten, der die Aktivitätsanforderung darstellt
consumerGroup Zeichenfolge, die die Verbrauchergruppe enthält, die verwendet wird, um Daten aus dem Thema zu konsumieren
sessionTimeoutMS Ganzzahl, die die Zeit (in Millisekunden) angibt, um Clientfehler zu erkennen, wenn die Gruppenverwaltungsfunktion von Apache Kafka verwendet wird
maxPollRecords Ganzzahl, die die maximale Anzahl von Datensätzen angibt, die in einem einzelnen Aufruf zurückgegeben werden
topic Zeichenfolge mit dem Namen des Themas, das die Nachrichten enthält
pollDurationSec Ganzzahl, die die Zeit (in Sekunden) angibt, nach der ein leerer Datensatz zurückgegeben wird, wenn keine Nachrichten abgerufen werden
Response Schema Node/Field Beschreibung
getMessagesResponse Knoten, der die Aktivitätsantwort darstellt
message Knoten, der die abgerufene Nachricht darstellt
item Knoten, der die Elemente innerhalb einer Nachricht darstellt
key Zeichenfolge, die den Schlüssel der abgerufenen Nachricht enthält
value Zeichenfolge, die den Wert der abgerufenen Nachricht enthält
offset Zeichenfolge, die den Offset enthält, dem die Nachricht zugewiesen ist
topic Zeichenfolge mit dem Namen des Themas, zu dem die Nachricht gehört

  • Aktualisieren: Klicken Sie auf das Aktualisierungssymbol oder das Wort Aktualisieren, um Schemata vom Apache Kafka-Endpunkt neu zu generieren. Diese Aktion regeneriert auch ein Schema an anderen Stellen im Projekt, an denen dasselbe Schema referenziert wird, wie zum Beispiel in einer benachbarten Transformation.

  • Zurück: Klicken Sie, um die Konfiguration für diesen Schritt vorübergehend zu speichern und zum vorherigen Schritt zurückzukehren.

  • Fertig: Klicken Sie, um die Konfiguration für alle Schritte zu speichern und die Aktivitätskonfiguration zu schließen.

  • Änderungen verwerfen: Nach Änderungen klicken Sie, um die Konfiguration zu schließen, ohne die an einem Schritt vorgenommenen Änderungen zu speichern. Eine Nachricht fragt Sie, ob Sie die Änderungen wirklich verwerfen möchten.

Nächste Schritte

Nachdem Sie eine Apache Kafka Nachrichten abrufen-Aktivität konfiguriert haben, vervollständigen Sie die Konfiguration der Operation, indem Sie andere Aktivitäten oder Werkzeuge als Operation Schritte hinzufügen und konfigurieren. Sie können auch die Betriebseinstellungen konfigurieren, die die Möglichkeit umfassen, Operationen zusammenzuführen, die sich in denselben oder unterschiedlichen Workflows befinden.

Menüaktionen für eine Aktivität sind im Projektbereich und auf der Entwurfsgrafik zugänglich. Für Details siehe Aktivitätsaktionsmenü in Connector-Grundlagen.

Apache Kafka Nachrichten abrufen-Aktivitäten können als Quelle mit diesen Betriebsmustern verwendet werden:

Um die Aktivität mit Skriptfunktionen zu verwenden, schreiben Sie die Daten an einen temporären Speicherort und verwenden Sie dann diesen temporären Speicherort in der Skriptfunktion.

Wenn Sie bereit sind, bereitstellen und ausführen Sie die Operation und validieren Sie das Verhalten, indem Sie die Betriebsprotokolle überprüfen.