Overview
Aprenda a conectar el conector de MongoDB Kafka a MongoDB mediante un identificador uniforme de recursos (URI). Un URI de conexión es una cadena que contiene la siguiente información:
Se requiere la dirección de su implementación de MongoDB
Configuración de conexión opcional
Configuración de autenticación opcional
Credenciales de autenticación opcionales
El siguiente es un ejemplo de una URI de conexión para un conjunto de réplicas de MongoDB:
mongodb://mongodb0.example.com:27017,mongodb1.example.com:27017,mongodb2.example.com:27017/?replicaSet=myRepl
Para obtener más información sobre el formato URI de conexión, consulte Formato de URI de cadena de conexión en el manual de MongoDB.
Requisitos previos
Para conectar el conector MongoDB Kafka a MongoDB, debe otorgarle al usuario de la base de datos cualquiera de los siguientes:
el
readWriterollos roles
readAnyDatabaseyclusterMonitor
Cómo conectarse
Especifique un URI de conexión con la siguiente opción de configuración tanto en un conector de origen como en un conector de destino:
connection.uri=<your connection uri>
Para obtener más información sobre esta opción de configuración, consulte los siguientes recursos:
Cómo configurar su conexión
El Conector Kafka de MongoDB utiliza el controlador Java de MongoDB para analizar la URI de su conexión. El controlador Java de MongoDB es un artefacto que permite que aplicaciones Java como Kafka Connect interactúen con MongoDB.
Importante
Versión del controlador
La versión 2.0 del conector MongoDB Kafka utiliza la versión 4.7 del controlador Java MongoDB.
Para saber qué opciones de URI de conexión están disponibles en el conector, consulte la Guía de conexión del controlador Java de MongoDB.
Autenticación
Todos los mecanismos de autenticación disponibles en el controlador Java de MongoDB están disponibles en el conector MongoDB Kafka.
El siguiente es un ejemplo de una URI de conexión que se autentica con MongoDB mediante la autenticación SCRAM-SHA-256:
mongodb://<db_username>:<db_password>@<hostname>:<port>/?authSource=<authenticationDb>&authMechanism=SCRAM-SHA-256
Importante
Cargar secretos
Para evitar almacenar sus secretos de autenticación como texto sin formato en connection.uri la configuración, cárguelos desde una ubicación segura al iniciar el conector. Para saber cómo cargarlos al iniciar el conector, consulte la guía "Externalizar secretos" de Confluent.
Para saber qué mecanismos de autenticación están disponibles, consulte la guía de mecanismos de autenticación del controlador Java de MongoDB.
Para aprender más sobre la autenticación en el conector, consulta la Guía de seguridad y autenticación.