Zum Inhalt springen

Apache Kafka Send Message-Aktivität in Jitterbit Studio

Einführung

Eine Apache Kafka Send Message-Aktivität sendet mithilfe ihrer Apache Kafka-Verbindung Datenströme in ein Topic in einem Apache Kafka-Cluster und ist als Ziel zum Verarbeiten von Daten in einem Vorgang vorgesehen.

Erstellen einer Apache Kafka Send Message-Aktivität

Eine Instanz einer Apache Kafka Send Message-Aktivität wird aus einer Apache Kafka-Verbindung mithilfe ihres Send Message-Aktivitätstyps 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 Erstellen einer Aktivitäts- oder Tool-Instanz in Komponentenwiederverwendung.

Eine vorhandene Apache Kafka Send Message-Aktivität kann an diesen Orten bearbeitet werden:

Konfigurieren einer Apache Kafka Send Message-Aktivität

Führen Sie diese Schritte aus, um eine Apache Kafka Send Message-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 Send Message-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. Weitere 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
sendMessagesRequest Knoten, der die Aktivitätsanfrage darstellt
messages Knoten, der die gesendete Nachricht darstellt
item Knoten, der die Elemente innerhalb der gesendeten Nachricht darstellt
topic String mit dem Namen des Themas, an das die Nachricht gesendet wird
message String mit der Nachricht
Response-Schema-Knoten/Feld Beschreibung
sendMessagesResponse Knoten, der die Aktivitätsantwort darstellt
response Knoten, der die Antwort darstellt
item Knoten, der die Elemente innerhalb der Antwort darstellt
success Boolean mit dem Erfolg (true) oder Fehler (false) des Nachrichtenabrufs
message String mit der Nachricht
topic String mit dem Namen des Themas, an das die Nachricht gesendet wurde
error Knoten mit Fehlern
errorMessage String mit Fehlermeldungen, falls zutreffend

  • 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 das gleiche 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 die Änderungen verwerfen möchten.

Nächste Schritte

Nach der Konfiguration einer Apache-Kafka-Aktivität Nachricht senden 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 Designoberfläche zugänglich. Weitere Informationen finden Sie unter Aktivitätsaktionsmenü in Connector-Grundlagen.

Apache-Kafka-Aktivitäten Nachricht senden können als Ziel 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 bereit, stellen Sie die Operation bereit und führen Sie sie aus und validieren Sie das Verhalten, indem Sie die Operationsprotokolle überprüfen.