Typ Kafka

Cluster-Adresse

Tragen Sie hier Hostname und Port des Brokers im Kafka-Cluster ein. Wenn Sie mehrere Broker gleichzeitig adressieren wollen, trennen Sie die einzelnen Einträge durch Kommas (z. B. 'hostname1:9092, hostname2:9092, hostname3:9092').

Cluster-Verbindungssicherheit

Unterschiedliche Verschlüsselungs- und Authentifizierungsmethoden werden unterstützt. Je nach ausgewählter Option sind weitere Eingaben erforderlich.

• PLAINTEXT

Daten werden im Klartext ausgetauscht, keine weiteren Eingaben

• SSL

Für die SSL-Kommunikation sind Zertifikate erforderlich. Sie können Zertifikate im zentralen Zertifikatspeicher in ibaPDA abgelegen und verwalten. Detaillierte Informationen zum Zertifikatspeicher finden Sie im ibaPDA-Handbuch.

Im Dropdown-Menü Client Zertifikat stehen die verwendbaren Zertifikate zur Auswahl. Darüber hinaus stehen weitere Optionen zur Auswahl.

Aktivieren der SSL-Verifikation

Wenn Sie die SSL-Verifikation aktivieren, wird das Zertifikat des Kafka-Servers automatisch verifiziert. Dazu muss unter den Zertifikaten in ibaPDA das Aussteller-Zertifikat vorhanden sein, mit dem das Kafka-Server-Zertifikat signiert wurde.

Hinweis

Nutzung von verketteten SSL-Zertifikaten Sie können in ibaPDA auch verkettete Zertifikate importieren. Beim Import (z. B. als PEM-Datei oder PFX-Datei) werden die verketteten Zertifikate in einzelne Zertifikate aufgeteilt. Nach dem Import eines verketteten Zertifikats existieren daher mehrere einzelne Einträge unter den Zertifikaten. Wenn das Kafka-Server-Zertifikat über eine Kette von Aussteller-Zertifikaten signiert wurde und Sie gleichzeitig die SSL-Verifikation nutzen wollen, ist die Konfiguration des Keystores im Kafka-Server wichtig: Wenn der Keystore neben dem Kafka-Server-Zertifikat auch die komplette Kette der Aussteller-Zertifikate enthält, dann muss nur das Zertifikat der Root CA in ibaPDA vorhanden sein. Wenn der Keystore dagegen ausschließlich das Kafka-Server-Zertifikat enthält, muss in ibaPDA die vollständige Kette der Aussteller-Zertifikate vorhanden sein, damit die Verifizierung möglich ist.

• SASL/PLAINTEXT

Wählen Sie den SASL-Authentifizierungsmechanismus aus:

• • PLAIN (alle Daten werden im Klartext ausgetauscht)

  • SCRAM-SHA-256

  • SCRAM-SHA-512

Geben Sie den Benutzername sowie das Kennwort für die Anmeldung am Kafka-Cluster in den entsprechenden Feldern ein.

• SASL/SSL

Wie bei SASL/PLAINTEXT wählen Sie den SASL-Mechanismus aus und geben Benutzername und Kennwort ein. Im Drop-down-Menü Client Zertifikat stehen die verwendbaren Zertifikate zur Auswahl.

Für die Aktivierung und Nutzung der SSL-Verifikation gelten ebenfalls die Hinweise aus dem Abschnitt zur Cluster-Verbindungssicherheit mit SSL.

Schema Registry-Adresse

Aktivieren Sie diese Option, wenn im Kafka-Cluster eine Schema Registry genutzt wird. Tragen Sie dann hier Hostname und Port der Schema Registry ein. Je nach genutzter Verbindungssicherheit muss die Adresse mit "http://" oder "https://" beginnen. Standardmäßig ist diese Option deaktiviert.

Schema Registry-Verbindungssicherheit

ibaPDA unterstützt unterschiedliche Methoden für die Verbindungssicherheit. Je nach ausgewählter Option sind weitere Eingaben erforderlich.

• HTTP

Keine weitere Eingabe erforderlich

• HTTPS

Für die HTTPS-Kommunikation sind Zertifikate erforderlich. Im Drop-down-Menü Client Zertifikat stehen die verwendbaren Zertifikate zur Auswahl.

Die Auswahl eines Zertifikats sowie die Aktivierung und Nutzung der SSL-Verifikation erfolgen wie bereits bei der Cluster-Verbindungssicherheit mit SSL beschrieben.

• HTTP + Authentication

Diese Methode erfordert die Eingabe von Benutzername und Kennwort.

• HTTPS + Authentication

Wie HTTPS, zusätzlich ist die Eingabe von Benutzername und Kennwort erforderlich.

Telegramm-Timeout

Zeit in Sekunden, die ibaPDA auf eine Antwort aus dem Kafka-Cluster wartet. Der Wert entspricht dem Parameter message.timeout.ms in der Bibliothek librdkafka.

Acknowledgement-Modus

• Kein: Datennachrichten werden als kontinuierlicher Strom geendet, jedoch ohne Bestätigung, ob der Leader sie empfangen hat oder nicht. Dies ist der schnellste Modus, aber es ist nicht garantiert, dass der Broker die Daten erfasst hat.

• Leader: ibaPDA wartet, bis der Topic-Leader die Erfassung der gesendeten Daten bestätigt. Wenn der Leader nach dem Senden der Bestätigung ausfällt und bevor die Follower den Datensatz repliziert haben, gehen die Daten verloren.

• Alle: ibaPDA sendet keine neuen Daten, bis der Topic-Leader und die Follower die jeweilige Aufzeichnung der Daten bestätigt haben.

Der Wert entspricht dem Parameter acks in der Bibliothek librdkafka.

Message Batching Time

Zeit in Millisekunden, die ibaPDA wartet, um Nachrichten zu senden. Wenn der Wert 0 ist, werden Nachrichten so schnell wie möglich an den Kafka-Cluster gesendet. Wenn der Wert auf z. B. 100 ms eingestellt ist, werden alle 100 ms Pakete mit gepufferten Nachrichten gesendet. Dies erhöht die Latenzzeit, verringert aber den Verarbeitungsaufwand sowohl auf der Seite von ibaPDA als auch auf der Cluster-Seite.

Der Wert entspricht dem Parameter linger.ms in der Bibliothek librdkafka.

Zusätzliche Parameter

Sie können zusätzliche Parameter der Bibliothek librdkafka konfigurieren.

In der Tabelle sind bereits angelegte Parameter mit Namen und Wert aufgelistet. Neben der Liste befinden sich Buttons mit folgenden Funktionen:

	Parameter hinzufügen Geben Sie in die Spalten Schlüssel und Wert den Namen und einen Wert ein.
	Markierten Parameter löschen
	Parameter importieren Sie können Parameter aus einer CSV-Datei importieren, indem Sie im Dateibrowser die CSV-Datei auswählen.
	Parameter exportieren Sie können Parameter in eine CSV-Datei exportieren. Geben Sie einen Dateinamen ein und wählen einen Speicherort aus.

Hinweis
	In der Liste konfigurierte Parameter haben immer Vorrang und überschreiben ggf. andere Einstellungen. Die Dokumentation der in der Bibliothek librdkafka verfügbaren Parameter finden Sie unter: https://github.com/edenhill/librdkafka/blob/master/CONFIGURATION.md