Zum Inhalt springen

Apache Kafka Nachrichten abrufen Aktivität

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 Daten in einem Vorgang 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. Für Details siehe Erstellen einer Aktivitäts- oder Toolinstanz in Komponentenwiederverwendung.

Eine vorhandene Apache Kafka Nachrichten abrufen Aktivität kann von diesen Orten 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.

Apache Kafka Get Messages-Aktivitätskonfiguration Schritt 1

  • Name: Geben Sie einen Namen ein, um die Aktivität zu identifizieren. Der Name muss für jede Apache Kafka Get Messages-Aktivität einzigartig 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: Nach Änderungen 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.

Apache Kafka Get Messages-Aktivitätskonfiguration Schritt 2

  • Datenschemas: Diese Datenschemas werden von benachbarten 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:

Anforderungs-Schema-Knoten/-Feld 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 bei Verwendung der Gruppenverwaltungsfunktion von Apache Kafka zu erkennen
maxPollRecords Ganzzahl der maximalen Anzahl von Datensätzen, die in einem einzelnen Aufruf zurückgegeben werden
topic Zeichenfolge mit dem Namen des Themas, das die Nachrichten enthält
pollDurationSec Ganzzahl der Zeit (in Sekunden), nach der ein leeres Datensatzset zurückgegeben wird, wenn keine Nachrichten abgerufen werden
Antwortschema 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 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 Schemas 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 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 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 operationale 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. Weitere Informationen finden Sie im 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 den Betrieb und validieren Sie das Verhalten, indem Sie die Betriebsprotokolle überprüfen.