Overview
Aprende cómo conectar el MongoDB Kafka Connector a MongoDB usando un Identificador Uniforme de Recursos de conexión (URI). Un URI de conexión es un string que contiene la siguiente información:
La dirección de tu implementación de MongoDB es necesaria
Configuración de conexión opcional
Configuración de autenticación opcional
Credenciales de autenticación opcional
El siguiente es un ejemplo de URI de conexión para un set de réplicas de MongoDB:
mongodb://mongodb0.example.com:27017,mongodb1.example.com:27017,mongodb2.example.com:27017/?replicaSet=myRepl
Para aprender más sobre el formato URI de conexión, consulta Formato de URI de cadena de conexión en el Manual de MongoDB.
Requisitos previos
Para conectar el MongoDB Kafka Connector a MongoDB, se debe conceder al usuario de base de datos cualquiera de los siguientes permisos:
el rol
readWritetanto los roles de
readAnyDatabasecomo declusterMonitor
Cómo conectarse
Especifica un URI de conexión con la siguiente opción de configuración tanto en el conector origen como en el destino:
connection.uri=<your connection uri>
Para obtener más información sobre esta opción de configuración, consulta los siguientes recursos:
Cómo configurar su conexión
El Conector Kafka de MongoDB utiliza el controlador Java de MongoDB para analizar tu URI de conexión. El driver 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 MongoDB Kafka Connector utiliza la versión 4.7 del controlador Java de MongoDB.
Para saber qué opciones de URI de conexión están disponibles en el conector, consulta la guía de conexión del driver Java de MongoDB.
Autenticación
Todos los mecanismos de autenticación disponibles en el driver Java de MongoDB están disponibles en el Kafka Connector de MongoDB.
A continuación, se muestra un ejemplo de un URI de conexión que se autentica con MongoDB utilizando 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 tus secretos de autenticación como texto sin formato en tu configuración de connection.uri, carga tus secretos desde una ubicación segura a medida que se inicie tu conector. Para aprender a cargar tus secretos a medida que tu conector se inicia, consulte la guía de externalización de secretos de Confluent.
Para conocer qué mecanismos de autenticación se encuentran disponibles, consulta la Guía de mecanismos de autenticación del driver Java de MongoDB.
Para aprender más sobre la autenticación en el conector, consulta la Guía de seguridad y autenticación.