Zum Inhalt springen

Apache Kafka Get Messages-Aktivität in Jitterbit Studio

Einführung

Eine Apache Kafka Get Messages-Aktivität ruft mithilfe ihrer Apache Kafka-Verbindung Datenströme aus einem Topic in einem Apache Kafka-Cluster ab und dient als Quelle zur Bereitstellung von Daten in einem Vorgang.

Apache Kafka Get Messages-Aktivität erstellen

Eine Instanz einer Apache Kafka Get Messages-Aktivität wird aus einer Apache Kafka-Verbindung mit dem Aktivitätstyp Get Messages erstellt.

Um eine Aktivitätsinstanz zu erstellen, ziehen Sie den Aktivitätstyp auf die Design-Canvas oder kopieren Sie den Aktivitätstyp und fügen Sie ihn auf der Design-Canvas ein. Weitere Informationen finden Sie unter Aktivitäts- oder Tool-Instanz erstellen in Komponentenwiederverwendung.

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

Apache Kafka Get Messages-Aktivität konfigurieren

Führen Sie diese Schritte aus, um eine Apache Kafka Get Messages-Aktivität zu konfigurieren:

Schritt 1: Namen eingeben

Geben Sie in diesem Schritt einen Namen für die Aktivität ein. Jedes Benutzeroberflächenelement dieses Schritts wird nachfolgend beschrieben.

  • Endpunkt-Menü: Wenn mehrere Endpunkte desselben Connector-Typs konfiguriert sind, wird oben auf dem Bildschirm ein Menü mit dem aktuellen Endpunktnamen angezeigt. Klicken Sie auf das Menü, um zu einem anderen Endpunkt zu wechseln. Weitere Informationen finden Sie unter Zugewiesenen Endpunkt ändern in Konfigurationsbildschirme.

    • Endpunkt bearbeiten: Wird angezeigt, wenn Sie den Mauszeiger über den aktuellen Endpunktnamen bewegen. Klicken Sie, um die Verbindungskonfiguration 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 und beenden: 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 zu wechseln. Die Konfiguration wird erst gespeichert, wenn Sie auf der letzten Seite auf die Schaltfläche Fertig klicken.

  • Änderungen verwerfen: Klicken Sie nach dem Vornehmen von Änderungen, um die Konfiguration zu schließen, ohne Änderungen an einem Schritt zu speichern. Eine Meldung fordert Sie auf zu bestätigen, dass Sie die Änderungen verwerfen möchten.

Schritt 2: Datenschemas überprüfen

Alle vom Endpunkt generierten Request- oder Response-Schemas werden angezeigt. Jedes Benutzeroberflächenelement dieses Schritts wird nachfolgend beschrieben.

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

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

Die Request- und Response-Datenschemas bestehen aus diesen Knoten und Feldern:

Request-Schema-Knoten/Feld Beschreibung
getMessagesRequest Knoten, der die Aktivitätsanfrage darstellt
consumerGroup String mit der Consumer-Gruppe zum Verarbeiten von Daten aus dem Topic
sessionTimeoutMS Integer für die Zeit (in Millisekunden) zum Erkennen von Client-Fehlern bei Verwendung von Apache Kafkas Gruppenverwaltung
maxPollRecords Integer für die maximale Anzahl von Datensätzen, die in einem einzelnen Aufruf zurückgegeben werden
topic String mit dem Namen des Topics, das die Nachrichten enthält
pollDurationSec Integer für die Zeit (in Sekunden), nach der ein leerer Datensatz zurückgegeben wird, wenn keine Nachrichten abgerufen werden
Response-Schema-Knoten/Feld 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 String mit dem Schlüssel der abgerufenen Nachricht
value String mit dem Wert der abgerufenen Nachricht
offset String mit dem Offset, dem die Nachricht zugewiesen ist
topic String mit dem Namen des Topics, zu dem die Nachricht gehört

  • Aktualisieren: Klicken Sie auf das Aktualisierungssymbol oder das Wort Aktualisieren, um Schemas vom Apache-Kafka-Endpunkt neu zu generieren. Diese Aktion generiert auch ein Schema an anderen Stellen im Projekt neu, an denen auf dasselbe Schema verwiesen wird, z. B. in einer angrenzenden 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: Klicken Sie nach dem Vornehmen von Änderungen, um die Konfiguration zu schließen, ohne Änderungen an einem Schritt zu speichern. Eine Meldung fordert Sie auf zu bestätigen, dass Sie Änderungen verwerfen möchten.

Nächste Schritte

Nach der Konfiguration einer Apache-Kafka-Aktivität Get Messages schließen Sie die Konfiguration des Vorgangs ab, indem Sie weitere Aktivitäten oder Tools als Vorgangsschritte hinzufügen und konfigurieren. Sie können auch die Vorgangseinstellungen konfigurieren, die die Möglichkeit bieten, Vorgänge zu verketten, die sich in denselben oder verschiedenen Workflows befinden.

Menüaktionen für eine Aktivität sind über den Projektbereich und die Design-Canvas zugänglich. Weitere Informationen finden Sie unter Aktionsmenü für Aktivitäten in Connector-Grundlagen.

Apache-Kafka-Aktivitäten Get Messages können als Quelle mit diesen Vorgangsmustern verwendet werden:

Um die Aktivität mit Scripting-Funktionen zu verwenden, schreiben Sie die Daten an einen temporären Speicherort und verwenden Sie diesen temporären Speicherort dann in der Scripting-Funktion.

Wenn alles bereit ist, stellen Sie die Operation bereit und führen Sie sie aus und validieren Sie das Verhalten, indem Sie die Operationsprotokolle überprüfen.