JavaScript doit être activé pour que ce contenu s'affiche correctement
Connexion à Confluent Kafka
Découvrez comment créer une connexion à Confluent Kafka, que vous utilisez avec la connexion Registre de schémas Confluent, pour servir de source ou de cible dans un déploiement Big Data OCI GoldenGate.
Configurez les stratégies requises pour activer l'accès sécurisé au coffre et aux clés secrètes, telles que l'utilisation de clés secrètes, l'utilisation de coffres et la lecture de groupes de clés secrètes. Pour plus d'informations, reportez-vous à Stratégies minimales recommandées.
Créer une connexion source
Pour créer une connexion à Confluent Kafka source, procédez comme suit :
Sur la page de présentation d'OCI GoldenGate, cliquez sur Connexions.
Vous pouvez également cliquer sur Créer une connexion sous la section Introduction et passer à l'étape 3.
Sur la page Connexions, cliquez sur Créer une connexion.
Dans la page Créer une connexion, renseignez les champs comme suit :
Dans Nom, saisissez le nom de la connexion.
(Facultatif) Dans Description, entrez une description permettant de distinguer la connexion des autres.
Dans Compartiment, sélectionnez le compartiment dans lequel créer la connexion.
Dans la liste déroulante Type, sélectionnez Confluent Kafka.
Sous les serveurs de démarrage :
Saisissez le numéro d'hôte et le numéro de port du serveur de démarrage. Entrez l'adresse IP privée uniquement si le nom d'hôte ne peut pas être résolu à partir de votre sous-réseau ou s'il utilise SSL/TLS.
Remarques :
Si vous entrez une adresse IP privée, OCI GoldenGate réécrit l'adresse IP privée au format ip-10-0-0-0.ociggsvc.oracle.vcn.com.
Conseil :
Tous les noeuds du cluster doivent disposer de noms de domaine qualifiés complets pour permettre le transit sur des adresses privées.
(Facultatif) Cliquez sur + Serveur de démarrage pour ajouter un autre serveur de démarrage.
Dans Protocole de sécurité, sélectionnez l'une des options suivantes :
Texte normal
SASL sur texte brut, puis indiquez le nom d'utilisateur et le mot de passe.
SASL sur SSL, puis fournissez les valeurs de nom d'utilisateur, de mot de passe, de truststore et de fichier de clés si nécessaire.
SSL, puis fournissez les valeurs de truststore et de fichier de clés si nécessaire.
Développez Afficher les options avancées. Vous pouvez configurer les options suivantes :
Sécurité
Désélectionnez Utiliser les clés secrètes de coffre pour lesquelles vous préférez ne pas utiliser de clés secrètes de mot de passe pour cette connexion. Si cette option n'est pas sélectionnée :
Sélectionnez Utiliser la clé de cryptage gérée par Oracle pour laisser Oracle s'occuper de la gestion de toutes les clés de cryptage.
Sélectionnez Utiliser la clé de cryptage gérée par le client pour sélectionner une clé de cryptage spécifique stockée dans OCI Vault afin de crypter les informations d'identification de connexion.
Connectivité réseau
Adresse partagée, pour partager une adresse avec le déploiement affecté. Vous devez autoriser la connectivité à partir de l'adresse IP entrante du déploiement.
Adresse dédiée, pour le trafic réseau via une adresse dédiée dans le sous-réseau affecté de votre VCN. Vous devez autoriser la connectivité à partir des adresses IP entrantes de cette connexion.
Remarques :
Si l'affectation d'une connexion dédiée reste annulée pendant sept jours, le service la convertit en connexion partagée.
ParamètresPour effectuer une capture à partir de Kafka, créez un fichier de propriétés de consommateur Kafka avec l'un des désérialiseurs ou convertisseurs suivants :
Propriétés de consommateur Kafka pour le désérialiseur JSON :
Balises : ajoutez des balises pour organiser vos ressources.
Cliquez sur Créer.
La connexion apparaît dans la liste Connexions. Vous pouvez la sélectionner pour en afficher les détails. Veillez également à créer une connexion au registre de schémas de configuration, puis à affecter les deux connexions à un déploiement Big Data.
Créer une connexion cible
Pour créer une connexion à Confluent Kafka cible, procédez comme suit :
Sur la page de présentation d'OCI GoldenGate, cliquez sur Connexions.
Vous pouvez également cliquer sur Créer une connexion sous la section Introduction et passer à l'étape 3.
Sur la page Connexions, cliquez sur Créer une connexion.
Dans la page Créer une connexion, renseignez les champs comme suit :
Dans Nom, saisissez le nom de la connexion.
(Facultatif) Dans Description, entrez une description permettant de distinguer la connexion des autres.
Dans Compartiment, sélectionnez le compartiment dans lequel créer la connexion.
Dans la liste déroulante Type, sélectionnez Confluent Kafka.
Sous les serveurs de démarrage :
Sélectionnez une méthode de routage du trafic :
Saisissez le numéro d'hôte et le numéro de port du serveur de démarrage. Entrez l'adresse IP privée uniquement si le nom d'hôte ne peut pas être résolu à partir de votre sous-réseau ou s'il utilise SSL/TLS.
Remarques :
Si vous entrez une adresse IP privée, OCI GoldenGate réécrit l'adresse IP privée au format ip-10-0-0-0.ociggsvc.oracle.vcn.com.
Conseil :
Tous les noeuds du cluster doivent disposer de noms de domaine qualifiés complets pour permettre le transit sur des adresses privées.
(Facultatif) Cliquez sur + Serveur de démarrage pour ajouter un autre serveur de démarrage.
Dans Protocole de sécurité, sélectionnez l'une des options suivantes :
Texte normal
SASL sur texte brut, puis indiquez le nom d'utilisateur et le mot de passe.
SASL sur SSL, puis fournissez les valeurs de nom d'utilisateur, de mot de passe, de truststore et de fichier de clés si nécessaire.
SSL, puis fournissez les valeurs de truststore et de fichier de clés si nécessaire.
Développez Afficher les options avancées. Vous pouvez configurer les options suivantes :
Sécurité
Désélectionnez Utiliser les clés secrètes de coffre pour lesquelles vous préférez ne pas utiliser de clés secrètes de mot de passe pour cette connexion. Si cette option n'est pas sélectionnée :
Sélectionnez Utiliser la clé de cryptage gérée par Oracle pour laisser Oracle s'occuper de la gestion de toutes les clés de cryptage.
Sélectionnez Utiliser la clé de cryptage gérée par le client pour sélectionner une clé de cryptage spécifique stockée dans OCI Vault afin de crypter les informations d'identification de connexion.
Connectivité réseau
Adresse partagée, pour partager une adresse avec le déploiement affecté. Vous devez autoriser la connectivité à partir de l'adresse IP entrante du déploiement.
Adresse dédiée, pour le trafic réseau via une adresse dédiée dans le sous-réseau affecté de votre VCN. Vous devez autoriser la connectivité à partir des adresses IP entrantes de cette connexion.
Remarques :
Si l'affectation d'une connexion dédiée reste annulée pendant sept jours, le service la convertit en connexion partagée.
Balises : ajoutez des balises pour organiser vos ressources.
Cliquez sur Créer.
La connexion apparaît dans la liste Connexions. Vous pouvez la sélectionner pour en afficher les détails. Veillez également à créer une connexion au registre de schémas de configuration, puis à affecter les deux connexions à un déploiement Big Data.
Créer une connexion à Confluent Cloud avec des liens privés
Private Link vous permet d'accéder à votre cluster Confluent Cloud exécuté sur un cloud tiers via une adresse privée qui existe dans votre réseau virtuel.
Avant de créer la connexion, assurez-vous que vous disposez des éléments suivants :
Créez une connectivité de réseau privé entre Oracle Cloud Infrastructure (OCI) et le cloud tiers cible.
Lors de l'ajout d'une configuration réseau pour un lien privé dans Confluent Cloud, assurez-vous de sélectionner Résolution DNS privée.
Configurez les zones DNS et les enregistrements DNS dans le cloud tiers où vous avez configuré Confluent Cloud et dans OCI. Dans OCI, vous pouvez créer des zones dans les vues privées de votre VCN. Dans les zones, vous pouvez ajouter les enregistrements DNS requis.
Vous pouvez utiliser les instructions ci-dessus pour créer la connexion, mais à la place des étapes 5 et 6, procédez comme suit :
Pour l'étape 3e :
Fournissez les détails de port et d'hôte des serveurs Bootstrap.
Vous pouvez ajouter plusieurs serveurs Bootstrap.
Pour 3f :
Pour le protocole de sécurité, sélectionnez SASL over Plaintext.
Saisissez le nom utilisateur et le mot de passe.
Résoudre les erreurs de connexion Kafka
La plupart des problèmes de connexion entraînent des erreurs TimeoutException. Exemple :
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.
Si vous rencontrez ce message dans votre fichier de rapport Replicat, vous pouvez :
Assurez-vous que la rubrique cible est présente ou vérifiez que la création automatique de rubrique est activée dans les paramètres Kafka cible.
Assurez-vous qu'aucune règle de pare-feu ne bloque le trafic.
Si vous exécutez Kafka sur OCI avec une adresse privée, assurez-vous d'utiliser le nom de domaine qualifié complet interne en tant que serveur de démarrage dans server.properties et dans la connexion Kafka.
Si vous êtes connecté à un cloud confluent avec des adresses privées :
Assurez-vous que les zones DNS et les enregistrements DNS sont configurés correctement dans OCI et dans le cloud tiers cible.
Assurez-vous que la connexion réseau entre OCI et le cloud cible fonctionne correctement.
Vérifiez que vous pouvez vous connecter au cloud Confluent cible avec OpenSSL (openssl s_client -connect <bootstrap>) à partir d'une machine virtuelle OCI exécutée sur le même sous-réseau connecté au cloud tiers.
Vérifiez que vous pouvez publier ou utiliser des messages à partir d'un client Kafka exécuté sur OCI dans le même sous-réseau connecté au cloud tiers. En cas d'échec, vérifiez vos paramètres réseau sur OCI et le cloud tiers.