Konfigurieren Sie einen ETL-Verbraucher (Extract Transform Load)

  • Freigeben Version: Zurich
  • Aktualisiert 31. Juli 2025
  • 2 Minuten Lesedauer
  • Importieren und verarbeiten Sie Daten aus Ihrer Kafka-Umgebung mit Ihren vorhandenen RTE-Konfigurationen (robust Transform Engine).

    Vorbereitungen

    Warum und wann dieser Vorgang ausgeführt wird

    Um einen Verbraucher zu konfigurieren, müssen Sie zwei Datensätze erstellen.
    1. Der Verbraucherdatensatz, der angibt, wie Daten importiert und verarbeitet werden.
    2. Ein Datensatz für den Kafka-Stream, der den Datenstrom für Ihren Verbraucher definiert.
    Diese Aufgabe deckt die Verbrauchererstellung ab. Anweisungen zum Erstellen eines Kafka-Streams finden Sie unter Erstellen Sie einen Kafka-Stream.

    Prozedur

    1. Navigieren zu Alle > IntegrationHub > Verbraucher > ETL-Verbraucheran.
    2. Wählen Sie Neu.
    3. Füllen Sie die Felder des Formulars aus.
      Tabelle : 1. Kafka-ETL-Verbraucher
      Feld Beschreibung
      Name Name des ETL-Verbrauchers.
      Robuster Transformator für Importsatz Name des robusten Importsatz-Transformators, der zum Verarbeiten von Daten verwendet werden soll.
      Liefergarantie Bei einem Knotenfehler Option zum Festlegen der Zustellgarantie für eingehende Nachrichten. Wählen Sie eine der folgenden Antworten aus.
      • Keine verlorenen, sondern Duplikate : Alle Nachrichten werden mindestens einmal zugestellt. Einige Nachrichten werden möglicherweise mehrmals zugestellt.
      • Einmal oder überhaupt nicht : Eine Nachricht wird nicht mehrmals zugestellt. Einige Nachrichten werden möglicherweise überhaupt nicht zugestellt.
      Serialisierungsformat Das Serialisierungsformat für die Nachricht. Wählen Sie eine der folgenden Antworten aus.
      • Nur-Text : Wählen Sie diese Option für alle nur-Text-Nachrichten aus. Dies ist das Standardformat.
      • Codiert : Wählen Sie diese Option für Nachrichten in einem aus Apache Avro-Format. Das Konvertieren von nur-Text-Nachrichten in ein Avro-Format erfordert ein Schema. Wählen Sie die Schemaregistrierung in aus Schemaregistrierung Feld. Weitere Informationen zu Schemas finden Sie unter Schemaverwaltung in Stream Connect.
      Daten in einzelner Spalte Option, damit die Importsatztabelle Daten in einer Spalte speichert.
      Spaltenzuordnung Option, um anzugeben, ob der JSON-Schlüssel der Nachricht die Daten dem Namen oder der Bezeichnung der Spalte in der Importsatztabelle zugeordnet werden soll. Wählen Sie eine der folgenden Antworten aus.
      • Bezeichnung
      • Spaltenname
      Dieses Feld wird nur angezeigt, wenn Daten in einer einzelnen Spalte Kontrollkästchen ist deaktiviert.
      Anwendung Anwendungsbereich für den ETL-Verbraucher.
      Schemaregistrierung
      Registrierung für das ausgewählte Schema. Wählen Sie eine der folgenden Antworten aus.
      • Eigenständige Schemaregistrierung
      • Confluent-Schemaregistrierung

      Dieses Feld wird nur angezeigt, wenn Serialisierungsformat Ist auf festgelegt Codiert .

      Wenn sich die Schema-ID der empfangenen Nachricht für die Confluent-Schemaregistrierung nicht in der Schematabelle befindet, importiert das System das Schema dynamisch mithilfe der konfigurierten REST-Verbindung.

    4. Wählen Sie Speichern.

    Nächste Maßnahme

    Erstellen Sie einen Kafka-Stream Für diesen Verbraucher. Nachdem der Stream aktiviert wurde, können Sie Nachrichten aus Ihrer Kafka-Umgebung empfangen.