Verbindung zu Confluent Kafka herstellen
Hier erfahren Sie, wie Sie eine Verbindung zu Confluent Kafka erstellen, die Sie mit der Confluent Schema Registry-Verbindung verwenden, um als Quelle oder Ziel in einem OCI GoldenGate Big Data-Deployment zu dienen.
Bevor Sie beginnen
- Lesen Sie, wie OCI GoldenGate eine Verbindung zu Ihrer Quelle und Ihren Zielen herstellt.
- Konfigurieren Sie die erforderlichen Policys, um den sicheren Vault- und Secrets-Zugriff zu aktivieren, wie Secrets verwenden, Vaults verwenden und Secret-Bundles lesen. Weitere Informationen finden Sie unter Minimale empfohlene Policys.
Quellverbindung erstellen
Zielverbindung erstellen
Verbindung zu Confluent Cloud mit privaten Links erstellen
Mit Private Link können Sie über einen privaten Endpunkt, der in Ihrem virtuellen Netzwerk vorhanden ist, auf Ihr Confluent Cloud-Cluster zugreifen, das in einer Drittanbieter-Cloud ausgeführt wird.
Bevor Sie die Verbindung erstellen, müssen Sie Folgendes sicherstellen:
- Erstellen Sie eine private Netzwerkkonnektivität zwischen Oracle Cloud Infrastructure (OCI) und der Drittanbieter-Ziel-Cloud.
- Stellen Sie beim Hinzufügen der Netzwerkkonfiguration für einen privaten Link in Confluent Cloud sicher, dass Sie "Private DNS-Auflösung" auswählen.
- Konfigurieren Sie DNS-Zonen, und richten Sie DNS-Datensätze in der Drittanbieter-Cloud ein, in der Sie Confluent Cloud und in OCI konfiguriert haben. In OCI können Sie Zonen in den privaten Ansichten Ihres VCN erstellen. Innerhalb von Zonen können Sie die erforderlichen DNS-Datensätze hinzufügen.
Sie können die obigen Anweisungen zum Erstellen der Verbindung verwenden. Führen Sie jedoch anstelle der Schritte 5 und 6 die folgenden Schritte aus:
- Für Schritt 3e:
- Geben Sie die Host- und Portdetails der Bootstrap-Server an.
- Sie können mehrere Bootstrap-Server hinzufügen.
- Für 3f:
- Wählen Sie für das Sicherheitsprotokoll die Option SASL über Plaintext aus.
- Geben Sie den Benutzernamen und das Kennwort ein.
Fehler bei Kafka-Verbindungen beheben
Die meisten Verbindungsprobleme führen zu TimeoutException-Fehlern. Beispiel:
A failure occurred sending a message to Kafka to topic [ggstest] org.apache.kafka.common.errors.TimeoutException: Topic ggstest not present in metadata after 60000/120000 ms.Wenn diese Meldung in der Replicat-Berichtsdatei angezeigt wird, können Sie:
- Stellen Sie sicher, dass das Zielthema vorhanden ist, oder prüfen Sie, ob die automatische Themenerstellung in den Kafka-Zieleinstellungen aktiviert ist.
- Stellen Sie sicher, dass keine Firewallregeln den Datenverkehr blockieren.
- Wenn Sie Kafka auf OCI mit einem privaten Endpunkt ausführen, stellen Sie sicher, dass Sie den internen FQDN als Bootstrap-Server in server.properties und in der Kafka-Verbindung verwenden.
- Wenn Sie eine Verbindung zu einer Confluent Cloud mit privaten Endpunkten herstellen:
- Stellen Sie sicher, dass die DNS-Zonen und DNS-Datensätze sowohl in OCI als auch in der Drittanbieter-Ziel-Cloud ordnungsgemäß konfiguriert sind.
- Stellen Sie sicher, dass die Netzwerkverbindung zwischen OCI und der Ziel-Cloud ordnungsgemäß funktioniert.
- Testen Sie, ob Sie über eine OCI-VM, die im selben Subnetz ausgeführt wird, das mit der Drittanbieter-Cloud verbunden ist, eine Verbindung zur Confluent Cloud mit OpenSSL (
openssl s_client -connect <bootstrap>) herstellen können. - Testen Sie, ob Sie Nachrichten von einem Kafka-Client veröffentlichen oder konsumieren können, der auf OCI im selben Subnetz ausgeführt wird, das mit der Drittanbieter-Cloud verbunden ist. Wenn dies nicht erfolgreich ist, prüfen Sie Ihre Netzwerkeinstellungen in OCI und der Drittanbieter-Cloud.