Diese Seite wurde von der Cloud Translation API übersetzt.

Informationen zu den unterstützten Connectors für Application Integration.

Apache Kafka-Trigger

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

Hinweise

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

Connector-Administrator (roles/connectors.admin)

Weitere 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:

Application Integration Invoker (roles/integrations.integrationInvoker)

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

Beschränkung

Für den Apache Kafka-Trigger gelten die folgenden Einschränkungen:

Unterstützt das SASL_SSL-Sicherheitsprotokoll 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:

Rufen Sie in der Google Cloud Console die Seite Application Integration auf.
Zu „Application Integration“
Klicken Sie im Navigationsmenü auf Integrationen.
Die Seite Liste der Integrationen wird angezeigt. Dort sind alle Integrationen aufgeführt, die im Google Cloud-Projekt verfügbar sind.
Wählen Sie eine vorhandene Integration aus oder klicken Sie auf Integration erstellen, um eine neue zu erstellen.
Wenn Sie eine neue Integration erstellen, gehen Sie so vor:
1. Geben Sie im Bereich 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 Details des Dienstkontos einer Integration jederzeit im Bereich Integrationsübersicht in der Symbolleiste für Integrationen ändern oder aktualisieren.
  Hinweis:Die Option zum Auswählen eines Dienstkontos wird nur angezeigt, wenn Sie die Integrationsverwaltung für die ausgewählte Region aktiviert haben.
4. Klicken Sie auf Erstellen.
Dadurch wird die Integration auf der Seite Integrationseditor geöffnet.
Klicken Sie in der Navigationsleiste des Integrationseditors auf Trigger, um eine Liste der verfügbaren Trigger aufzurufen.
Klicken Sie auf das Element Apache Kafka-Trigger und platzieren Sie es im Integrationseditor.

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 mithilfe der Option zum Erstellen einer Inline-Verbindung erstellen.

Apache Kafka-Trigger mit einer vorhandenen Verbindung konfigurieren

Sie können den Apache Kafka-Trigger mit einer vorhandenen Apache Kafka-Verbindung in Integration Connectors konfigurieren. Der Apache Kafka-Trigger ist ein Connector-Ereignistrigger. Sie können den Trigger daher nur mit einer Apache Kafka-Verbindung mit aktiviertem Ereignisabo konfigurieren.

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

So konfigurieren Sie einen Apache Kafka-Trigger mit einer vorhandenen Apache Kafka-Verbindung:

Klicken Sie im Integrationseditor auf das Element Apache Kafka-Trigger, um den Bereich für die Triggerkonfiguration zu öffnen.
Klicken Sie auf Trigger konfigurieren.
Geben Sie auf der Seite Connector Event Trigger Editor (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.
  In der Anwendungsintegration werden nur die Apache Kafka-Verbindungen angezeigt, die aktiv sind und für die ein Ereignisabo aktiviert ist.
3. Themenname: Geben Sie den Namen des Themas ein.
4. Nutzergruppen-ID: Optional können Sie die Nutzergruppen-ID eingeben, 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. Mit Partitionen können Sie ein Thema in mehrere Teile aufteilen und jeden Teil auf einem anderen Knoten im Cluster speichern.
6. Anfangsversatz: Wählen Sie die Strategie zum Zurücksetzen des Versatzes aus:
  - Wenn Sie earliest auswählen, werden über Ihre Verbindung nicht verwendete Nachrichten verbraucht, einschließlich aller Nachrichten, die vor der Lebensdauer der Verbrauchergruppe erstellt wurden.
  - Wenn Sie latest auswählen, werden über die Verbindung Nachrichten verarbeitet, die nach dem Erstellen der Verbrauchergruppe generiert werden.
7. Dienstkonto: Wählen Sie ein Dienstkonto mit den erforderlichen IAM-Rollen für den Apache Kafka-Trigger aus.
Klicken Sie auf Fertig.

Apache Kafka-Trigger mit einer neuen Verbindung konfigurieren

So konfigurieren Sie den Apache Kafka-Trigger mit einer neuen Apache Kafka-Verbindung:

Klicken Sie im Integrationseditor auf das Element Apache Kafka-Trigger, um den Bereich für die Triggerkonfiguration zu öffnen.
Klicken Sie auf Apache Kafka-Trigger konfigurieren.
Überspringen Sie das Feld Region.
Klicken Sie auf Verbindung und wählen Sie in der Liste die Option Verbindung erstellen aus. Der Bereich Create Connection (Verbindung erstellen) wird angezeigt.
Wählen Sie im Schritt Standort den Standort für die neue Apache Kafka-Verbindung aus:
1. Region:Wählen Sie eine Region aus der Liste aus.
2. Klicken Sie auf Weiter.
Geben Sie im Schritt Verbindungsdetails Details zur neuen Apache Kafka-Verbindung ein:
1. Connector-Version:Wählen Sie eine verfügbare Version des Apache Kafka-Connectors aus der Liste aus.
2. 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 49 Zeichen haben.
  - Bei Konnektoren, die Ereignisanmeldungen unterstützen, dürfen die Verbindungsnamen nicht mit dem Präfix „goog“ beginnen.
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 Protokolldaten 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 für die Apache Kafka-Verbindung standardmäßig ausgewählt.
  Hinweis : Dieser Connector unterstützt die Option Enable only event subscription nicht.
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 wird.
11. Registry-Nutzer: Nutzername oder Zugriffsschlüsselwert, der für die Autorisierung mit dem in RegistryUrl angegebenen Server verwendet werden soll.
12. Registry-Passwort: Secret Manager-Secret mit dem Passwort/Secret-Schlüsselwert zum Autorisieren mit dem in RegistryUrl angegebenen Server.
13. Optional: Konfigurieren Sie die Verbindungsknoteneinstellungen:
  - 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.
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: Dieses Feld legt fest, ob SSL aktiviert ist.
16. Klicken Sie auf Weiter.
Geben Sie im Abschnitt Ziele die Details zum Kafka-Bootstrap-Server ein, mit dem Sie eine Verbindung herstellen möchten.
1. Zieltyp: Wählen Sie einen Zieltyp aus.
  - Wählen Sie in der Liste Hostadresse aus, um den Hostnamen oder die IP-Adresse des Ziels anzugeben.
  - Wenn Sie eine private Verbindung zu Ihren Backend-Systemen herstellen möchten, wählen Sie in der Liste Endpunktanhang 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 konfigurieren, um nur bestimmte statische IP-Adressen zuzulassen.
  
  Wenn Sie weitere Kafka-Bootstrap-Server angeben möchten, klicken Sie auf + ZIEL HINZUFÜGEN.
2. Klicken Sie auf Weiter.
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-Schema: Das Schema, das für die Authentifizierung verwendet wird.
      Die folgenden Authentifizierungsschemata werden 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.
Geben Sie die Konfiguration für den Postfach-Alias ein. Wenn Sie ein Dead-Letter-Thema konfigurieren, schreibt die Verbindung die nicht verarbeiteten Ereignisse in das angegebene Pub/Sub-Thema. Geben Sie die folgenden Informationen ein:
1. Dead-Letter-Projekt-ID : Die Google Cloud-Projekt-ID, in der Sie das Dead-Letter-Pub/Sub-Thema konfiguriert haben.
2. Dead-Letter-Thema : Das Pub/Sub-Thema, in das Sie die Details des nicht verarbeiteten Ereignisses schreiben möchten.
Klicken Sie auf Weiter.
Überprüfen: Prüfen Sie Ihre Verbindungs- und Authentifizierungsdetails.
Klicken Sie auf Erstellen.

Trigger-Ausgabe

Bei Verwendung des Apache Kafka-Triggers dauert es einige Minuten, bis die Konfiguration des Ereignisabonnements abgeschlossen ist. Den Status Ihres Ereignisabonnements finden Sie im Bereich „Triggerkonfiguration“ unter Details zum Ereignisabonnement.

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

Creating: Gibt an, dass der Trigger das Ereignisabo abonniert.
Active: Gibt an, dass für den Trigger ein Ereignisabo abonniert wurde.
Error: Gibt an, dass ein Problem mit dem konfigurierten Ereignisabo vorliegt.

Im Bereich Details zum Ereignisabo werden neben dem Status des Ereignisabos auch weitere Details wie die Verbindungsregion, der Verbindungsname und der Name des Ereignisabos angezeigt.

Trigger-Ausgabevariable

Für jedes Ereignis generiert der Apache Kafka-Trigger eine ConnectorEventPayload-Ausgabevariable (im JSON-Format), die Sie in nachgelagerten Aufgaben verwenden können. Die Ausgabevariable enthält die Nutzlast aus Ihrem 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 Ereignisabonnements auf, die mit einer Verbindung in Integration Connectors verknüpft sind, und verwalten sie:

Rufen Sie die Seite Integration Connectors > Verbindungen auf.
Zur Seite „Verbindungen“
Klicken Sie auf die Verbindung, für die Sie die Abos aufrufen möchten.
Klicken Sie auf den Tab Ereignisabos.
Daraufhin werden alle Ereignisabonnements für die Verbindung angezeigt.

Apache Kafka-Trigger bearbeiten

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

So bearbeiten Sie einen Apache Kafka-Trigger:

Klicken Sie im Integrationseditor auf das Element Apache Kafka-Trigger, um den Bereich für die Triggerkonfiguration zu öffnen.
Klicken Sie auf Apache Kafka-Trigger konfigurieren.
Führen Sie auf der Seite Connector-Ereignistrigger-Editor die folgenden Schritte aus:
1. Wenn Sie das zuvor konfigurierte Ereignisabo beibehalten möchten, klicken Sie auf Beibehalten. Andernfalls klicken Sie auf Löschen.
  Warnung:Wenn Sie ein Ereignisabo löschen, wirkt sich das 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 zum Ereignisabo nach Bedarf.
3. Klicken Sie auf Fertig.

Die aktualisierten Details zur Verbindung und zum Ereignisabo finden Sie im Bereich „Triggerkonfiguration“ unter Details zum Ereignisabo.

Kontingente und Limits

Weitere Informationen zu allen Kontingenten und Limits finden Sie unter Kontingente und Limits.