Hier finden Sie die unterstützten Connectors für Application Integration.

Apache Kafka-Trigger

Vorschau — Apache Kafka trigger

Diese Funktion unterliegt den „Nutzungsbedingungen für Pre-GA-Angebote“ im Abschnitt „Allgemeine Nutzungsbedingungen“ der dienstspezifischen Nutzungsbedingungen. Pre-GA-Funktionen sind „wie besehen“ verfügbar und werden möglicherweise nur eingeschränkt unterstützt. Weitere Informationen finden Sie in den Beschreibungen der Startphase.

Der Apache Kafka-Trigger ist ein Connector-Ereignis-Trigger, mit dem Sie eine Integration aufrufen können, die auf den Apache Kafka-Ereignissen basiert, die Sie in Ihrer Apache Kafka-Verbindung abonniert haben.

Wichtig:Integration Connectors ist eine kostenpflichtige Komponente von Google Cloud. Informationen zu den Kosten und Gebühren für die Verwendung von Integration Connectors finden Sie unter Preise für Integration Connectors.

Hinweise

Wenn Sie eine neue Verbindung für den Apache Kafka-Trigger erstellen oder konfigurieren möchten, benötigen Sie die folgende IAM-Rolle (Identity and Access Management) für das Projekt:

• Connectors-Administrator (roles/connectors.admin)

Informationen zum Zuweisen von Rollen finden Sie unter Zugriff verwalten.

Weisen Sie dem Dienstkonto, das Sie für den Apache Kafka-Trigger verwenden möchten, die folgenden IAM-Rollen zu:

• Aufrufer von Application Integration (roles/integrations.integrationInvoker)

Informationen zum Zuweisen von Rollen zu einem Dienstkonto finden Sie unter Zugriff auf Dienstkonten verwalten.

Beschränkung

Der Apache Kafka-Trigger unterliegt den folgenden Einschränkungen:

• Unterstützt das Sicherheitsprotokoll SASL_SSL für Ereignisabos.
• mTLS wird für Ereignisabos nicht unterstützt.

Apache Kafka-Trigger hinzufügen

So fügen Sie Ihrer Integration einen Apache Kafka-Trigger hinzu:

1. Rufen Sie in der Google Cloud Console die Seite Application Integration auf.

   Zu Application Integration

2. Klicken Sie im Navigationsmenü auf Integrations (Integrationen).

   Auf der Seite Integrationsliste werden alle im Google Cloud-Projekt verfügbaren Integrationen aufgeführt.

3. Wählen Sie eine vorhandene Integration aus oder klicken Sie auf Verknüpfung erstellen, um eine neue zu erstellen.

   Wenn Sie eine neue Integration erstellen:

   1. Geben Sie im Bereich Create Integration (Integration erstellen) einen Namen und eine Beschreibung ein.
   2. Wählen Sie eine Region für die Integration aus.
      Hinweis: Im Drop-down-Menü Regionen werden nur die in Ihrem Google Cloud-Projekt bereitgestellten Regionen aufgeführt. Klicken Sie zum Bereitstellen einer neuen Region auf Region aktivieren. Weitere Informationen finden Sie unter Neue Region aktivieren.
   3. Wählen Sie ein Dienstkonto für die Integration aus. Sie können die Dienstkontodetails einer Integration jederzeit in der Symbolleiste der Verknüpfung im Bereich Zusammenfassung ändern oder aktualisieren.
      Hinweis:Die Option zur Auswahl eines Dienstkontos wird nur angezeigt, wenn Sie die Integration Governance für die ausgewählte Region aktiviert haben.
   4. Klicken Sie auf Erstellen.

   Dadurch wird die Integration auf der Seite Integrationseditor geöffnet.

4. Klicken Sie in der Navigationsleiste des Integrationseditors auf Trigger, um die Liste der verfügbaren Trigger aufzurufen.
5. Klicken Sie im Integrationseditor auf das Element Apache Kafka-Trigger und platzieren Sie es dort.

Zum Konfigurieren des Apache Kafka-Triggers können Sie entweder eine vorhandene Apache Kafka-Verbindung verwenden, die in Integration Connectors verfügbar ist, oder eine neue Apache Kafka-Verbindung mit der Option zum Erstellen von Inline-Verbindungen erstellen.

Apache Kafka-Trigger mithilfe einer vorhandenen Verbindung konfigurieren

Sie können den Apache Kafka-Trigger mithilfe einer vorhandenen Apache Kafka-Verbindung in Integration Connectors konfigurieren. Der Apache Kafka-Trigger ist ein Trigger für Connector-Ereignisse. Daher können Sie zum Konfigurieren des Triggers nur eine Apache Kafka-Verbindung mit aktiviertem Ereignisabo verwenden.

Informationen zum Konfigurieren eines Apache Kafka-Triggers über eine neue Apache Kafka-Verbindung finden Sie unter Apache Kafka-Trigger mit einer neuen Verbindung konfigurieren.

So konfigurieren Sie einen Apache Kafka-Trigger über eine vorhandene Apache Kafka-Verbindung:

1. Klicken Sie im Integrationseditor auf das Element Apache Kafka-Trigger, um den Bereich für die Triggerkonfiguration zu öffnen.
2. Klicken Sie auf Trigger konfigurieren.
3. Geben Sie auf der Seite Editor für Connector-Ereignistrigger die folgenden Konfigurationsdetails an:
   1. Region:Wählen Sie die Region Ihrer Apache Kafka-Verbindung aus.
   2. Verbindung:Wählen Sie die Apache Kafka-Verbindung aus, die Sie verwenden möchten.

      Application Integration zeigt nur die Apache Kafka-Verbindungen an, die aktiv sind und für die ein Ereignisabo aktiviert ist.

   3. Name des Themas: Geben Sie den Namen des Themas ein.
   4. Nutzergruppen-ID: Geben Sie optional die Nutzergruppen-ID ein, die den Namen der Nutzergruppe angibt, zu der der Kafka-Nutzer gehört.
   5. Partition: Geben Sie die Partition ein, wenn Sie eine bestimmte Partition abonnieren möchten. Partitionen sind eine Möglichkeit, ein Thema in mehrere Teile zu unterteilen und jeden Teil auf einem anderen Knoten im Cluster zu speichern.
   6. Anfänglicher Offset: Wählen Sie die Strategie zum Zurücksetzen des Offsets aus:
      • Wenn Sie frühestes auswählen, verarbeitet die Verbindung nicht genutzte Nachrichten, einschließlich aller Nachrichten, die vor der Lebensdauer der Nutzergruppe erstellt wurden.
      • Wenn Sie latest auswählen, verarbeitet die Verbindung Nachrichten, die nach dem Erstellen der Nutzergruppe erstellt wurden.
   7. Dienstkonto: Wählen Sie ein Dienstkonto mit den erforderlichen IAM-Rollen für den Apache Kafka-Trigger aus.
4. Klicken Sie auf Fertig.

Apache Kafka-Trigger mit einer neuen Verbindung konfigurieren

So konfigurieren Sie den Apache Kafka-Trigger über eine neue Apache Kafka-Verbindung:

1. Klicken Sie im Integrationseditor auf das Element Apache Kafka-Trigger, um den Bereich für die Triggerkonfiguration zu öffnen.
2. Klicken Sie auf Apache Kafka-Trigger konfigurieren.
3. Überspringen Sie das Feld Region.
4. Klicken Sie auf Connection (Verbindung) und wählen Sie die Option Create Connection (Verbindung erstellen) aus der Liste aus. Der Bereich Create Connection (Verbindung erstellen) wird angezeigt.
5. Wählen Sie im Schritt Speicherort den Speicherort für die neue Apache Kafka-Verbindung aus:
   1. Region:Wählen Sie eine Region aus der Liste aus.
   2. Klicken Sie auf Weiter.
6. Geben Sie im Schritt Verbindungsdetails Details zur neuen Apache Kafka-Verbindung an:
   1. Connector-Version:Wählen Sie eine verfügbare Version des Apache Kafka-Connectors aus der Liste aus.
   2. Connection Name (Verbindungsname): Geben Sie einen Namen für die Apache Kafka-Verbindung ein.
      Hinweis: Verbindungsnamen müssen die folgenden Kriterien erfüllen:

      • Verbindungsnamen können Buchstaben, Ziffern oder Bindestriche enthalten.
      • Buchstaben müssen Kleinbuchstaben sein.
      • Verbindungsnamen müssen mit einem Buchstaben beginnen und mit einem Buchstaben oder einer Ziffer enden.
      • Verbindungsnamen dürfen maximal 63 Zeichen haben.
   3. Optional: Beschreibung : Geben Sie eine Beschreibung für die Verbindung ein.
   4. (Optional) Cloud Logging aktivieren: Klicken Sie dieses Kästchen an, um alle Logdaten der Verbindung zu speichern.
   5. Dienstkonto: Wählen Sie ein Dienstkonto mit den erforderlichen IAM-Rollen für die Apache Kafka-Verbindung aus.
   6. Die Option Ereignisabo, Entität und Aktionen aktivieren ist standardmäßig für die Apache Kafka-Verbindung ausgewählt.
      Hinweis : Die Option Enable only event subscription wird von diesem Connector nicht unterstützt.
   7. Typerkennungsschema : Wählen Sie MessageOnly aus.
   8. Registry-Dienst: Der Schema Registry-Dienst, der zum Arbeiten mit Themenschemas verwendet wird.
   9. Registry-Typ: Typ des Schemas, das für ein bestimmtes Thema angegeben wurde.
   10. Registry Version: Version des Schemas, das für das angegebene Thema aus RegistryUrl gelesen wurde.
   11. Registry-Nutzer: Nutzername oder Zugriffsschlüsselwert, der mit dem in RegistryUrl angegebenen Server autorisiert werden soll.
   12. Registry-Passwort: Secret Manager-Secret mit dem Passwort bzw. geheimen Schlüsselwert, der mit dem in RegistryUrl angegebenen Server autorisiert werden soll.
   13. Konfigurieren Sie optional die Einstellungen für den Verbindungsknoten:
       • Mindestanzahl von Knoten: Geben Sie die Mindestanzahl von Verbindungsknoten ein.
       • Maximale Anzahl von Knoten: Geben Sie die maximale Anzahl von Verbindungsknoten ein.

       Ein Knoten ist eine Einheit (oder ein Replikat) einer Verbindung, die Transaktionen verarbeitet. Zur Verarbeitung von mehr Transaktionen für eine Verbindung sind mehr Knoten erforderlich. Umgekehrt sind weniger Knoten erforderlich, um weniger Transaktionen zu verarbeiten. Informationen zu den Auswirkungen der Knoten auf Ihre Connector-Preise finden Sie unter Preise für Verbindungsknoten. Wenn Sie keine Werte eingeben, ist die Mindestanzahl von Knoten standardmäßig auf 2 (für eine bessere Verfügbarkeit) und die maximale Knotenzahl auf 50 gesetzt.

   Hinweis: Sie können die Verbindungsknotenwerte nur anpassen, wenn Sie ein „Pay as you go”-Kunde sind.
   14. Klicken Sie optional auf + LABEL HINZUFÜGEN, um der Verbindung ein Label in Form eines Schlüssel/Wert-Paars hinzuzufügen.
   15. SSL aktivieren: In diesem Feld wird festgelegt, ob SSL aktiviert ist.
   16. Klicken Sie auf Weiter.
7. Geben Sie im Abschnitt Ziele die Details zum Remote-Host (Backend-System) ein, zu dem Sie eine Verbindung herstellen möchten.
   1. Destination Type: Wählen Sie einen Destination Type aus.
      • Wählen Sie aus der Liste Hostadresse aus, um den Hostnamen oder die IP-Adresse für das Ziel anzugeben.
      • Wenn Sie eine private Verbindung zu Ihren Back-End-Systemen herstellen möchten, wählen Sie Endpunktanhang aus der Liste und dann den erforderlichen Endpunktanhang aus der Liste Endpunktanhang aus.
        Hinweis: Informationen zum Erstellen eines Endpunktanhangs finden Sie unter PSC-Dienstanhang und Endpunktanhang. Nachdem Sie den Endpunktanhang erstellt haben, wird er in der Liste Endpunktanhang angezeigt.

      Wenn Sie eine öffentliche Verbindung zu Ihren Back-End-Systemen mit zusätzlicher Sicherheit herstellen möchten, können Sie statische ausgehende IP-Adressen für Ihre Verbindungen konfigurieren und dann Ihre Firewallregeln so konfigurieren, dass nur bestimmte statische IP-Adressen auf die Zulassungsliste gesetzt werden.

      Wenn Sie weitere Ziele eingeben möchten, klicken Sie auf + ZIEL HINZUFÜGEN.

   2. Klicken Sie auf Weiter.
8. Geben Sie im Abschnitt Authentifizierung die Authentifizierungsdetails ein.
   1. Wählen Sie einen Authentifizierungstyp aus und geben Sie die relevanten Details ein.

      Die folgenden Authentifizierungstypen werden von der Apache Kafka-Verbindung unterstützt:

      • Nutzername und Passwort
        • Nutzername: Der Apache Kafka-Nutzername für die Verbindung.
        • Passwort: Secret Manager-Secret, das das mit dem Apache Kafka-Nutzernamen verknüpfte Passwort enthält.
        • Auth Scheme (Authentifizierungsschema): Das für die Authentifizierung verwendete Schema.

          Das folgende Authentifizierungsschema wird von der Apache Kafka-Verbindung unterstützt:

          • Einfach
          • SCRAM-SHA-1
          • SCRAM-SHA-256
      • Nicht verfügbar

        Wenn Sie die anonyme Anmeldung verwenden möchten, wählen Sie Nicht verfügbar aus.

   2. Klicken Sie auf Weiter.
9. Geben Sie die Konfiguration für unzustellbare Nachrichten ein. Wenn Sie unzustellbare Nachrichten konfigurieren, schreibt die Verbindung die nicht verarbeiteten Ereignisse in das angegebene Pub/Sub-Thema. Geben Sie die folgenden Informationen ein:
   1. Projekt-ID für unzustellbare Nachrichten : Die ID des Google Cloud-Projekts, in dem Sie das Pub/Sub-Thema für unzustellbare Nachrichten konfiguriert haben.
   2. Thema für unzustellbare Nachrichten: Das Pub/Sub-Thema, in das Sie die Details des nicht verarbeiteten Ereignisses schreiben möchten.
10. Klicken Sie auf Weiter.
11. Überprüfen: Prüfen Sie Ihre Verbindungs- und Authentifizierungsdetails.
12. Klicken Sie auf Erstellen.

Trigger-Ausgabe

Der Apache Kafka-Trigger benötigt einige Minuten, um die Konfiguration des Ereignisabos abzuschließen. Sie können den Status Ihres Ereignisabos im Triggerkonfigurationsbereich unter Ereignisabodetails ansehen.

Der Apache Kafka-Trigger gibt den Status eines Ereignisabos mithilfe der folgenden Status an:

• Creating: Gibt an, dass der Trigger das Ereignisabo abonniert.
• Active: Gibt an, dass der Trigger ein Ereignisabo abonniert hat.
• Error: Gibt an, dass ein Problem mit dem konfigurierten Ereignisabo vorliegt.

Zusätzlich zum Ereignisabostatus werden im Bereich Ereignisabodetails auch andere Details wie Verbindungsregion, Verbindungsname und Ereignisaboname angezeigt.

Triggerausgabevariable

Für jedes Ereignis generiert der Apache Kafka-Trigger eine ConnectorEventPayload-Ausgabevariable (im JSON-Format), die Sie in Ihren nachgelagerten Aufgaben verwenden können. Die Ausgabevariable enthält die Nutzlast aus dem Apache Kafka-Ereignis. Beispiel:

  {
    "message": "{\"key\":\"18\",\"topic\":\"test\",\"value\":\"hello world\",\"partition\":0,\"offset\":12,\"headers\":\"{}\",\"timestamp\":1712755076824,\"serializedMessagesize\":14}",
    "contentType": "text/plain"
 }

Ereignisabos ansehen

So rufen Sie alle Ereignisabos auf, die mit einer Verbindung in Integration Connectors verknüpft sind:

1. Rufen Sie die Seite Integration Connectors > Verbindungen auf.

   Zur Seite „Verbindungen“

2. Klicken Sie auf die Verbindung, deren Abos Sie aufrufen möchten.
3. Klicken Sie auf den Tab Ereignisabos.

   Dadurch werden alle Ereignisabos für die Verbindung angezeigt.

Apache Kafka-Trigger bearbeiten

Sie können einen Apache Kafka-Trigger bearbeiten, um die Verbindungskonfiguration und die Details des Ereignisabos zu ändern oder zu aktualisieren.

Wichtig:Wenn Sie einen Apache Kafka-Trigger bearbeiten oder ändern, können Sie entweder das zuvor konfigurierte Ereignisabo beibehalten, das mit dem Trigger verknüpft ist, oder es löschen. Das Löschen eines Ereignisabos wirkt sich auf alle veröffentlichten Integrationen aus, die dieses Ereignisabo verwenden.

Führen Sie die folgenden Schritte aus, um einen Apache Kafka-Trigger zu bearbeiten:

1. Klicken Sie im Integrationseditor auf das Element Apache Kafka-Trigger, um den Bereich für die Triggerkonfiguration zu öffnen.
2. Klicken Sie auf Apache Kafka-Trigger konfigurieren.
3. Führen Sie auf der Seite Editor für Connector-Ereignistrigger die folgenden Schritte aus:
   1. Wenn Sie das zuvor konfigurierte Ereignisabo beibehalten möchten, klicken Sie auf Beibehalten oder auf Löschen.
      Warnung:Das Löschen eines Ereignisabos wirkt sich auf alle veröffentlichten Integrationen aus, die das Ereignisabo verwenden. Diese Aufgabe kann nicht rückgängig gemacht werden.
   2. Aktualisieren Sie die Verbindungskonfiguration und die Details des Ereignisabos nach Bedarf.
   3. Klicken Sie auf Fertig.

Die aktualisierten Verbindungs- und Ereignisabodetails finden Sie im Triggerkonfigurationsbereich unter Ereignisabodetails.