Sie können ein Verbindungsasset für den Zugriff auf Ihre Daten in Apache Kafka erstellen.
Apache Kafka ist eine verteilte Plattform für das Streamen von Ereignissen. Stellen Sie eine Verbindung zu einem Apache Kafka-Echtzeitverarbeitungsserver her, um Ereignisströme aus und in Topics zu schreiben und zu lesen.
Unterstützte Versionen
Apache Kafka Versionen 0.11 - 2.x
Eine Verbindung zu Apache Kafka erstellen
Zum Erstellen des Verbindungsassets benötigen Sie die folgenden Verbindungsdetails.
Kafka server hostname: Hostname und Portnummer für den Kafka -Server. Verwenden Sie das folgende Format: hostname:port-number
. Um eine Verbindung zu einem Kafka -Cluster herzustellen, trennen Sie die Werte durch Kommas: hostname1:port-number1,hostname2:port-number2,hostname3:port-number3
. Wenn Sie eine Verbindung zu einem Cluster herstellen, verwendet die Verbindung alle Server unabhängig davon, welche Server für das Bootstrapping angegeben sind. Da diese Server für die einleitende Verbindung verwendet werden, um die vollständige Clusterzugehörigkeit zu erkennen, die sich dynamisch ändern kann, muss diese Liste nicht alle Server enthalten. Wenn der Kafka -Cluster jedoch maximal drei Hosts aufweist, schließen Sie alle Hosts in diese Liste ein, um Datenverluste zu verhindern.
Sichere Verbindung
Wählen Sie das Netzauthentifizierungsprotokoll aus, das auf dem Kafka -Server eingerichtet ist. None ist der Standardwert. Dies sind die anderen Auswahlen und ihre Eigenschaften:
SASL OAUTHBEARER
Wählen Sie OAuth 2.0 aus.
- Server-URL: Tokenendpunkt-URL. Beispiel:
https://example.com/oauth2/default/v1/token
. - Client-ID: Die OAuth-Client-ID.
- Geheimer Clientschlüssel: Der geheime OAuth-Clientschlüssel
- Bereich Optionaler Bereich, auf den im Aufruf des OAuth-Servers verwiesen werden soll.
- Weitere Eigenschaften:Weitere OAuth-Konfigurationsoptionen. Als
key=value
-Paare eingeben. Der Wert dieser mehrzeiligen Eigenschaft muss den Anforderungen der Java-Eigenschaftsklasse entsprechen. - Truststore-Zertifikate: Vertrauenswürdige Zertifikate im PEM-Format Es werden nur X.509-Zertifikate unterstützt.
SASL_Plain
Name des Benutzerprinzipals: Der authentifizierte Benutzer im Kafka -Server oder -Cluster.
Kennwort: Das Kennwort für den Namen des Benutzerprinzipals.
SASL_SSL
Name des Benutzerprinzipals: Der authentifizierte Benutzer im Kafka -Server oder -Cluster.
Kennwort: Das Kennwort für den Namen des Benutzerprinzipals.
Truststore-Zertifikate: Truststore-Zertifikate im PEM-Format. Es werden nur X.509-Zertifikate unterstützt.
SCRAM-SHA-256 oder SCRAM-SHA-512
Name des Benutzerprinzipals: Der authentifizierte Benutzer im Kafka -Server oder -Cluster.
Kennwort: Das Kennwort für den Namen des Benutzerprinzipals.
Truststore-Zertifikate: Truststore-Zertifikate im PEM-Format. Es werden nur X.509-Zertifikate unterstützt.
SSL
Truststore-Zertifikate: Truststore-Zertifikate im PEM-Format. Es werden nur X.509-Zertifikate unterstützt.
Schlüssel: Privater Schlüssel im PEM-Format Der Schlüssel muss PKCS #8 -Syntax verwenden.
Schlüsselzertifikatskette: Zertifikatskette für den privaten Schlüssel im PEM-Format. Es werden nur X.509-Zertifikate unterstützt.
Schlüsselkennwort: Dieser Wert ist erforderlich, wenn der Schlüssel verschlüsselt ist.
Nachrichtenformat
Eine Schemaregistry ist eine Software anderer Anbieter, die die Nachrichten verwaltet und die Schemas Themen zuordnet, sodass Produzenten wissen, welche Themen welche Typen (Schemas) von Nachrichten akzeptieren, und Konsumenten wissen, wie sie Nachrichten in einem Thema lesen und analysieren können. Wenn Sie Schema-Registry für Nachrichtenformat verwendenauswählen, können Sie diese zusätzlichen Details auswählen, um eine sichere Verbindung zum Schema-Registry-Service herzustellen.
Voraussetzung
Richten Sie die Schemaregistrierung für Ihren Kafka mit Confluent (Confluent-Versionen 6.x und 7.x werden unterstützt) oder mit IBM Event Streams ein.
Schema-Registry-URL: Die URL zum Schema-Registry-Service.
Authentifizierung
Wählen Sie die Authentifizierungsmethode für den Schema-Registry-Service aus. None ist der Standardwert. Dies sind die anderen Auswahlen und ihre Eigenschaften:
Kafka -Server-SASL-Benutzerberechtigungsnachweise verwenden: Sie können diese Auswahl treffen, wenn Sie Eigenschaften für SASL_Plain oder SASL_SSL für die sichere Verbindung zum Kafka -Server eingegeben haben. Der Benutzername und das Kennwort für die SASL-Sicherheitseinstellungen werden für die Authentifizierung beim Schema-Registry-Service verwendet.
Benutzerberechtigungsnachweise: Benutzername und Kennwort für den Schema-Registry-Service.
Sichere Verbindung
Wählen Sie das sichere Netzauthentifizierungsprotokoll für den Schema-Registry-Service aus. None ist der Standardwert. Dies sind die anderen Auswahlen und ihre Eigenschaften:
SSL-Benutzerberechtigungsnachweise für Kafka -Server verwenden: Diese Option können Sie auswählen, wenn Sie Eigenschaften für SSL für die sichere Verbindung zum Kafka -Server eingegeben haben. Die Zertifikatskonfiguration aus der Kafka -Serververbindung wird für die sichere Verbindung zum Schema-Registry-Service verwendet.
SSL
- Truststore-Zertifikate: Truststore-Zertifikate im PEM-Format. Es werden nur X.509-Zertifikate unterstützt.
- Schlüssel: Privater Schlüssel im PEM-Format Der Schlüssel muss PKCS #8 -Syntax verwenden.
- Schlüsselzertifikatskette: Zertifikatskette für den privaten Schlüssel im PEM-Format. Es werden nur X.509-Zertifikate unterstützt.
- Schlüsselkennwort: Dieser Wert ist erforderlich, wenn der Schlüssel verschlüsselt ist.
Schemaregistry-Typ
Wählen Sie den Typ der Schemaregistrierung:
- Confluent
- IBM Event Streams (mit Confluent kompatible API)
Je nach Position auf der Plattform geeignete Methode zum Erstellen einer Verbindung auswählen
In einem Projekt
Klicken Sie auf Assets > Neues Asset > Verbindung zu einer Datenquelle herstellen. Weitere Informationen finden Sie unter Verbindung zu einem Projekt hinzufügen.
In einem Katalog
Klicken Sie auf Zu Katalog hinzufügen > Verbindung. Weitere Informationen finden Sie unter Verbindungsasset zu einem Katalog hinzufügen.
Klicken Sie im Platform assets catalog
auf Neue Verbindung. Weitere Informationen finden Sie unter Hinzufügen von Plattformverbindungen.
Nächster Schritt: Fügen Sie Datenassets aus der Verbindung hinzu
- Weitere Informationen finden Sie unter Daten aus einer Verbindung in einem Projekt hinzufügen.
- Weitere Informationen finden Sie unter Daten aus einer Verbindung in einem Katalog hinzufügen.
Wo Sie diese Verbindung verwenden können
Sie können die Apache Kafka-Verbindung in den folgenden Arbeitsbereichen und Tools verwenden:
Projekte
- Data Replication (Data Replication-Service). Sie können Daten aus anderen Datenbanken mit Data Replication in Apache Kafka replizieren. Weitere Informationen finden Sie unter Apache Kafka -Daten replizieren.
- DataStage (DataStage -Service) Siehe Verbindung zu einer Datenquelle in DataStage.
Kataloge
Platform assets catalog
Andere Kataloge (IBM Knowledge Catalog)
Hinweis:Vorschau, Profil und Maskierung sind für diese Verbindung im IBM Knowledge Catalog nicht zertifiziert.
Apache Kafka-Konfiguration
Weitere Informationen
Übergeordnetes Thema: Unterstützte Verbindungen