Apache Kafka-Verbindung
Einführung
Eine Apache Kafka-Verbindung, die mit dem Apache Kafka-Connector erstellt wurde, ermöglicht den Zugriff auf Apache Kafka. Sobald eine Verbindung konfiguriert ist, können Instanzen von Apache Kafka-Aktivitäten erstellt werden, die mit dieser Verbindung verknüpft sind, um entweder als Quellen (um Daten in einem Vorgang bereitzustellen) oder als Ziele (um Daten in einem Vorgang zu konsumieren) verwendet zu werden.
Hinweis
Dieser Connector unterstützt die Re-Authentifizierung bei Änderung Organisationsrichtlinie. Wenn aktiviert, erfordert eine Änderung des Benutzernamens in dieser Verbindung, dass die Benutzer das Passwort für die Verbindung erneut eingeben.
Erstellen oder Bearbeiten einer Apache Kafka-Verbindung
Eine neue Apache Kafka-Verbindung wird mit dem Apache Kafka-Connector aus einem dieser Standorte erstellt:
- Der Registerkarte Projektendpunkte und -connectoren in der Designkomponentenpalette (siehe Designkomponentenpalette).
- Der Seite Globale Endpunkte (siehe Erstellen eines globalen Endpunkts in Globalen Endpunkten).
Eine vorhandene Apache Kafka-Verbindung kann von diesen Standorten bearbeitet werden:
- Der Registerkarte Projektendpunkte und -connectoren in der Designkomponentenpalette (siehe Designkomponentenpalette).
- Der Registerkarte Komponenten im Projektbereich (siehe Menü für Komponentenaktionen in Projektbereich Komponenten-Registerkarte).
- Der Seite Globale Endpunkte (siehe Bearbeiten eines globalen Endpunkts in Globalen Endpunkten).
Konfigurieren einer Apache Kafka-Verbindung
Jedes Benutzeroberflächenelement des Konfigurationsbildschirms für die Apache Kafka-Verbindung wird im Folgenden beschrieben.
Tipp
Felder mit einem Symbol für Variablen unterstützen die Verwendung von globalen Variablen, Projektvariablen und Jitterbit-Variablen. Beginnen Sie entweder, indem Sie eine öffnende eckige Klammer [ in das Feld eingeben, oder indem Sie auf das Symbol für Variablen klicken, um ein Menü anzuzeigen, das vorhandene Variablen zur Auswahl auflistet.
-
Verbindungsname: Geben Sie einen Namen ein, um die Verbindung zu identifizieren. Der Name muss für jede Apache Kafka-Verbindung eindeutig sein und darf keine Schrägstriche
/oder Doppelpunkte:enthalten. Dieser Name wird auch verwendet, um den Apache Kafka-Endpunkt zu identifizieren, der sich sowohl auf eine spezifische Verbindung als auch auf deren Aktivitäten bezieht. -
Authentifizierungsmechanismus: Wählen Sie den SASL-Mechanismus, entweder GSSAPI oder PLAIN:
-
GSSAPI: Wählen Sie, wenn der Apache Kafka-Client den GSSAPI (Kerberos) Mechanismus verwendet.
-
PLAIN: Wählen Sie, wenn der Apache Kafka-Client den PLAIN Mechanismus (Benutzername/Passwort) verwendet.
-
-
Authentifizierungsprotokoll: Wählen Sie das Sicherheitsprotokoll, eines von SASL PLAINTEXT, SASL SSL oder SASL SSL (SCRAM-SHA-256):
-
SASL PLAINTEXT: Wählen Sie, wenn der Apache Kafka-Client das
SASL_PLAINTEXTSicherheitsprotokoll verwendet. -
SASL SSL: Wählen Sie, wenn der Apache Kafka-Client das
SASL_SSLSicherheitsprotokoll verwendet. -
SASL SSL (SCRAM-SHA-256): Wählen Sie, wenn der Apache Kafka-Client das SCRAM-SHA-256 Sicherheitsprotokoll verwendet (sichtbar nur, wenn PLAIN als Authentifizierungsmechanismus ausgewählt ist).
-
-
Bootstrap-Server: Geben Sie eine durch Kommas getrennte Liste von Bootstrap-Servern ein, die zur Herstellung der Verbindung zum Apache Kafka-Cluster verwendet werden sollen.
-
Benutzername: Geben Sie den Benutzernamen für den Apache Kafka-Client ein. Dieses Feld ist nur sichtbar, wenn PLAIN als Authentifizierungsmechanismus ausgewählt ist.
-
Passwort: Geben Sie das Passwort für den Apache Kafka-Client ein. Dieses Feld ist nur sichtbar, wenn PLAIN als Authentifizierungsmechanismus ausgewählt ist.
-
Test: Klicken Sie, um die Verbindung mit der bereitgestellten Konfiguration zu überprüfen. Wenn die Verbindung getestet wird, wird die neueste Version des Connectors von den Agenten in der Agentengruppe heruntergeladen, die mit der aktuellen Umgebung verbunden ist. Dieser Connector unterstützt das Aussetzen des Downloads der neuesten Connector-Version durch die Verwendung der Automatische Connector-Aktualisierung deaktivieren Organisationsrichtlinie.
-
Änderungen speichern: Klicken Sie, um die Konfiguration der Verbindung zu speichern und zu schließen.
-
Änderungen verwerfen: Nachdem Sie Änderungen an einer neuen oder bestehenden Konfiguration vorgenommen haben, klicken Sie, um die Konfiguration ohne Speichern zu schließen. Eine Nachricht fragt Sie, ob Sie die Änderungen verwerfen möchten.
-
Löschen: Nachdem Sie eine bestehende Verbindungs-Konfiguration geöffnet haben, klicken Sie, um die Verbindung dauerhaft aus dem Projekt zu löschen und die Konfiguration zu schließen (siehe Komponentenabhängigkeiten, Löschung und Entfernung). Eine Nachricht fragt Sie, ob Sie die Verbindung löschen möchten.
Nächste Schritte
Nachdem eine Apache Kafka-Verbindung erstellt wurde, platzieren Sie einen Aktivitätstyp auf der Entwurfsgrafik, um Aktivitätsinstanzen zu erstellen, die entweder als Quellen (um Daten in einem Vorgang bereitzustellen) oder als Ziele (um Daten in einem Vorgang zu konsumieren) verwendet werden.
Menüaktionen für eine Verbindung und ihre Aktivitätstypen sind im Projektbereich und in der Designkomponenten-Palette zugänglich. Für Details siehe Aktionsmenüs in Connector-Grundlagen.
Diese Aktivitätstypen sind verfügbar:
-
Nachricht senden: Sendet Datenströme in Themen in einem Apache Kafka-Cluster und ist dafür gedacht, als Ziel in einem Vorgang verwendet zu werden.
-
Nachrichten abrufen: Ruft Datenströme von Themen in einem Apache Kafka-Cluster ab und ist als Quelle in einer Operation vorgesehen.