Extrakt für Kafka-Quellen hinzufügen

Das Hinzufügen eines Extract für eine Kafka-Quelle unterscheidet sich zwischen Big Data-Deployment-Versionen. Befolgen Sie die Anweisungen entsprechend Ihrer OCI GoldenGate Big Data-Deployment-Version.

Um Ihre OCI GoldenGate-Version zu prüfen, zeigen Sie die Versionsinformationen auf der Seite mit den Deployment-Details an.

Sie können Nachrichten aus den folgenden Streamingquellen erfassen:

OCI GoldenGate liest Nachrichten aus einem oder mehreren Kafka-Themes und konvertiert die Daten dann in logische Änderungsdatensätze, die In GoldenGate-Traildateien geschrieben werden. GoldenGate Replicat-Prozesse können dann die generierten Traildateien verwenden, um Daten zur Unterstützung von RDBMS-Implementierungen (Relational Database Management System) zu propagieren.

Ein OCI GoldenGate Big Data-Deployment unterstützt mehrere Quelltechnologien innerhalb desselben Deployments, sodass Sie mehrere Extrakte aus verschiedenen unterstützten Quelltechnologien innerhalb desselben Deployments konfigurieren können. OCI GoldenGate verwendet Zugangsdatenspeichereinträge, um die Quelltechnologie zu identifizieren. Beispiel: OCI GoldenGate verwendet die Benutzer-ID der Zugangsdaten, um zu bestimmen, ob ein Kafka-(kafka://-) oder Mongo-(Mongo://-)Extrakt gestartet werden soll.

Extract hinzufügen (26ai)

Bevor Sie einen Extract hinzufügen und ausführen, müssen Sie Folgendes sicherstellen:

So fügen Sie einen Extract in Oracle GoldenGate 26ai hinzu:

  1. Wählen Sie im Navigationsmenü der OCI GoldenGate-Deployment-Konsole die Option Extracts aus.

  2. Wählen Sie auf der Seite "Extracts" die Option Extract hinzufügen aus.

  3. Füllen Sie im Bereich "Extract hinzufügen" auf der Seite Extract-Informationen die folgenden Felder nach Bedarf aus, und wählen Sie Weiter aus:

    • Geben Sie einen Prozessnamen ein, der nicht länger als 8 Zeichen ist.

    • Geben Sie eine Beschreibung (optional) ein, damit Sie diesen Prozess von anderen unterscheiden können.

    • Wählen Sie eine Quelle aus der Dropdown-Liste aus.

  4. Füllen Sie auf der Seite Extraktionsoptionen die folgenden Felder nach Bedarf aus, und wählen Sie Weiter aus:

    1. Für Extract Trail:

      1. Geben Sie einen Namen für den Extract-Prozess ein.

      2. Geben Sie einen Unterverzeichnisnamen ein, um einen benutzerdefinierten Speicherort für die generierte Traildatei festzulegen.

      3. Geben Sie Trailsequenz ein, um die Startnummer für Traildateien festzulegen.

      4. Geben Sie eine Trailgröße ein, um die maximale Größe für die generierte Traildatei festzulegen.

      5. Wählen Sie ein Verschlüsselungsprofil aus. Das Profil "Lokales Wallet" wird standardmäßig ausgewählt, wenn kein Verschlüsselungsprofil erstellt wurde.

      6. Wählen Sie einen Verschlüsselungsalgorithmus aus:

        • NONE

        • AES256

        • AES192

        • AES128

    2. Wählen Sie unter Quellzugangsdaten Folgendes aus:

      1. Domain

      2. Aliasname

      3. Wann/wo beginnt

  5. Füllen Sie auf der Seite Verwaltete Optionen die folgenden optionalen Felder nach Bedarf aus, und wählen Sie Weiter aus:

    • Profilname

    • Kritisch für den Deployment-Zustand

    • Autom. Start

    • Automatischer Neustart

      Hinweis: Wenn Sie ein Profil hinzufügen und die Optionen "Automatischer Start" und "Automatischer Neustart" konfigurieren, kann Ihr Deployment nach einer Netzwerkunterbrechung automatisch neu gestartet werden. Weitere Informationen finden Sie unter Verwaltete Prozesse konfigurieren.

  6. Aktualisieren Sie auf der Seite "Parameterdatei" Folgendes:

    1. Aktualisieren Sie SOURCEDB USERIDALIAS auf SOURCEDB USERIDALIAS kafka DOMAIN OracleGoldenGate.

    2. Lassen Sie die Tabellenzuordnung unverändert (TABLE source.*;), um alle Topics im angegebenen Bootstrap-Server zu überwachen. Um aus einem angegebenen Thema zu erfassen, ändern Sie die Zuordnung in TABLE source.<topic-name>;, wobei <topic-name> der Name des Themas ist, aus dem erfasst werden soll.

      Hinweis: Das Mappingformat "Extract" lautet Table SourceSchema.Table. In Kafka sind keine Quellschemas/Tabellen vorhanden. OCI GoldenGate schreibt den ersten Teil ("Quelle" im obigen Schritt) als Schemanamen und den zweiten Teil als Tabellennamen in die Traildatei. Auf diese Weise können Sie die erfasste Kafka-Nachricht in andere von GoldenGate unterstützte Ziele replizieren.

  7. Wählen Sie Erstellen und ausführen aus, um den Extract zu erstellen und auszuführen. Wenn Sie Erstellen auswählen, können Sie den Extract später auf der Seite "Exporte" manuell starten.

Extrahieren (21c)

Bevor Sie einen Extract erstellen, erstellen Sie Zugangsdaten in der Big Data-Deployment-Konsole:

  1. Wählen Sie auf der Seite "Deployments" das Big Data-Deployment aus, um seine Details anzuzeigen.

  2. Melden Sie sich bei der Big Data-Deployment-Konsole mit den Zugangsdaten an, die Sie beim Erstellen des Deployments angegeben haben. Sie gelangen zur Seite {\b Administration Server Overview}.

  3. Zugangsdaten hinzufügen:

    1. öffnen Sie das Navigationsmenü, und wählen Sie Konfiguration aus.

    2. Wählen Sie auf der Seite "Zugangsdaten" die Option Zugangsdaten hinzufügen (Plussymbol).

    3. Geben Sie die folgenden Details in die angegebenen Felder ein, und wählen Sie Weiterleiten aus:

      • Geben Sie unter Zugangsdatendomain OracleGoldenGate ein.

      • Geben Sie unter Zugangsdatenalias kafka ein.

      • Geben Sie unter Benutzer-ID kafka:// ein.

      • Geben Sie unter Kennwort ein Kennwort ein.

      • Geben Sie unter Verify Password (Passwort prüfen) das Passwort erneut ein.

So fügen Sie einen Extract für Kafka in OCI GoldenGate für Big Data-Deployments ab Version 21.9 hinzu:

  1. Wählen Sie im Navigationsmenü die Option Überblick, um zur Seite "Überblick" des Administrationsservice zurückzukehren.

  2. Wählen Sie Extract hinzufügen (Plussymbol).

  3. Wählen Sie auf der Seite "Extract hinzufügen" Folgendes aus, und wählen Sie Weiter aus:

    • Quelle: Kafka

    • Extraktionstyp: Change Data Capture Extract

  4. Füllen Sie auf der Seite "Extract-Optionen" die Felder folgendermaßen aus, und wählen Sie Weiter aus:

    • Geben Sie unter "Prozessname" einen Namen mit bis zu 8 Zeichen an.

    • (Optional) Geben Sie eine Beschreibung ein.

    • Wählen Sie für Verbindungsalias den zuvor zugewiesenen Verbindungsalias aus.

    • Wählen Sie für "Beginn" die Option Jetzt.

    • Geben Sie unter Trailname einen aus 2 Zeichen bestehenden Namen an.

    • (Optional) Aktivieren Sie Kafka Connect, wenn die Quelle ein Kafka Connect-Framework ist.

    • (Optional) Wenn Kafka Connect ausgewählt ist, wählen Sie einen der verfügbaren Konvertierer aus:

      • JSON

      • AVRO

    • (Optional) Wenn AVRO ausgewählt ist, wählen Sie Confluent Schema Registry aus.

    • (Optional) Unter "Verwaltete Optionen" können Sie Folgendes konfigurieren:

      • Profilname

      • Autom. Start

      • Automatischer Neustart

        Hinweis: Wenn Sie ein Profil hinzufügen und die Optionen "Automatischer Start" und "Automatischer Neustart" konfigurieren, kann Ihr Deployment nach einer Netzwerkunterbrechung automatisch neu gestartet werden. Weitere Informationen finden Sie unter Verwaltete Prozesse konfigurieren.

  5. Aktualisieren Sie auf der Seite "Parameterdatei" Folgendes:

    1. Aktualisieren Sie SOURCEDB USERIDALIAS auf SOURCEDB USERIDALIAS kafka DOMAIN OracleGoldenGate.

    2. Lassen Sie die Tabellenzuordnung unverändert (TABLE source.*;), um alle Topics im angegebenen Bootstrap-Server zu überwachen. Um aus einem angegebenen Thema zu erfassen, ändern Sie die Zuordnung in TABLE source.<topic-name>;, wobei <topic-name> der Name des Themas ist, aus dem erfasst werden soll.

      Hinweis: Das Mappingformat "Extract" lautet Table SourceSchema.Table. In Kafka sind keine Quellschemas/Tabellen vorhanden. OCI GoldenGate schreibt den ersten Teil ("Quelle") als Schemanamen und den zweiten Teil als Tabellennamen in die Traildatei. Auf diese Weise können Sie die erfasste Kafka-Nachricht in andere von GoldenGate unterstützte Ziele replizieren.

  6. Wählen Sie Erstellen und ausführen aus.

Kehren Sie zur Seite "Überblick" des Administrationsservice zurück und können den Extract-Status beobachten. Anschließend können Sie den Extract auswählen, um die zugehörigen Details, Statistiken und Berichte anzuzeigen.