Confluent-Kafka-Verbindung

Bei der Confluent-Kafka-Verbindung handelt es sich um eine Messaging-Verbindung. Verwenden Sie die Confluent-Kafka-Verbindung, um auf einen Kafka-Broker oder einen Confluent-Kafka-Broker als Quelle oder Ziel zuzugreifen. Sie können eine Confluent-Kafka-Verbindung im Developer Tool oder durch infacmd erstellen und verwalten.

Allgemeine Eigenschaften

Eigenschaft	Beschreibung
Name	Name der Verbindung. Der Name unterliegt nicht der Groß-/Kleinschreibung und muss innerhalb der Domäne eindeutig sein. Sie können diese Eigenschaft nach dem Erstellen der Verbindung ändern. Der Name darf nicht mehr als 128 Zeichen und weder Leerzeichen noch die folgenden Sonderzeichen enthalten: ~ ` ! $ % ^ & * ( ) - + = { [ } ] \| \ : ; " ' < , > . ? /
ID	Die Zeichenfolge, die der Datenintegrationsdienst zum Erkennen der Verbindung verwendet. Bei der ID wird die Groß- und Kleinschreibung nicht beachtet. Sie darf maximal 255 Zeichen umfassen und muss in der Domäne eindeutig sein. Sie können diese Eigenschaft nach dem Erstellen der Verbindung nicht mehr ändern. Als Standardwert dient der Verbindungsname.
Beschreibung	Beschreibung der Verbindung. Geben Sie eine Zeichenfolge ein, mit der Sie die Verbindung angeben können. Die Beschreibung darf nicht mehr als 4.000 Zeichen enthalten.
Speicherort	Die Domäne, in der Sie die Verbindung erstellen möchten. Wählen Sie den Domänennamen aus.
Typ	Verbindungstyp. Wählen Sie Messaging/ConfluentKafka aus.

Eigenschaften des Confluent-Kafka-Brokers

Eigenschaft	Beschreibung
Liste der Kafka Broker	Durch Kommas getrennte Liste der Confluent-Kafka-Broker, die die Konfiguration des Confluent-Kafka-Messaging-Brokers beibehalten. Verwenden Sie das folgende Format, um einen Confluent-Kafka-Broker anzugeben: <IP-Adresse>:<Port>
Timeout der Wiederholungen	Anzahl der Sekunden, nach denen der Datenintegrationsdienst versucht, erneut eine Verbindung zum Confluent-Kafka-Broker herzustellen, um Daten zu lesen oder zu schreiben. Ist die Quelle oder das Ziel für den angegebenen Zeitraum nicht verfügbar, wird die Zuordnungsausführung zur Vermeidung von Datenverlusten angehalten.
Kafka-Broker-Version	Die Version des Confluent-Kafka-Messaging-Brokers.
Zusätzliche Verbindungseigenschaften	Optional. Durch Kommas getrennte Liste der Verbindungseigenschaften, um eine Verbindung zum Kafka-Broker herzustellen.
URL der Schemaregistrierung	Speicherort und Port des Schemaregistrierungsanbieters, über den eine Verbindung hergestellt werden soll.

Zusätzliche Verbindungseigenschaften

request.timeout.ms=<value>,session.timeout.ms=<value>,
fetch.max.wait.ms=<value>,heartbeat.interval.ms=<value>,
security.protocol=SASL_PLAINTEXT,sasl.kerberos.
service.name=<kerberos name>,sasl.mechanism=GSSAPI,
sasl.jaas.config=com.sun.security.auth.module.
Krb5Login Modulerequired useKeyTab=true
doNotPrompt=true storeKey=true client=true
keyTab="<Keytab Location>" principal="<principal>";

SSL-Eigenschaften

Eigenschaft	Beschreibung
SSL-Modus	Optional. SSL-Modus, der den für die Verbindung zu verwendenden Verschlüsselungstyp angibt. Sie können einen der folgenden SSL-Modi wählen: - Deaktiviert - Unidirektional - Bidirektional Der Standardwert ist Deaktiviert.
SSL-TrustStore-Dateipfad	Erforderlich, wenn der SSL-Modus Unidirektional ausgewählt ist. Absoluter Pfad und Dateiname der SSL-Truststore-Datei, die Zertifikate des vertrauenswürdigen SSL-Servers enthält.
SSL-Truststore-Passwort	Erforderlich, wenn der SSL-Modus Unidirektional ausgewählt ist. Passwort für den SSL-Truststore.
SSL-KeyStore-Dateipfad	Erforderlich, wenn der SSL-Modus Bidirektional ausgewählt ist. Absoluter Pfad und Dateiname der SSL-Schlüsselspeicherdatei, die private Schlüssel und Zertifikate für den SSL-Server enthält.
SSL-Schlüsselspeicherpasswort	Erforderlich, wenn der SSL-Modus Bidirektional ausgewählt ist. Passwort für den SSL-Schlüsselspeicher.
Zusätzliche Sicherheitseigenschaften	Optional. Durch Kommas getrennte Liste der Verbindungseigenschaften, um eine sichere Verbindung zum Confluent-Kafka-Broker herzustellen.

Erstellen einer Confluent-Kafka-Verbindung mit infacmd

sh infacmd.sh createConnection -dn <domain name> -un <domain user> -pd <domain password> -cn <connection name> -cid <connection id> -ct ConfluentKafka -o "kfkBrkList='<host1:port1>,<host2:port2>,<host3:port3>' kafkabrokerversion='<version>' schemaregistryurl='<schema registry URL>'"