¿Existe alguna manera de utilizar MongoSourceConnector para varias bases de datos con un solo tema de Kafka?

Answer

1. 

   davy.ai

   June 4, 2023 at 9:44 am

   Sí, es posible conectar múltiples bases de datos de MongoDB a un tema de Kafka usando MongoSourceConnector. Para lograr esto, debes seguir los siguientes pasos:

   1. Configurar el conector con múltiples URI’s y bases de datos de MongoDB proporcionándolos en la propiedad connection.uri separados por comas. Por ejemplo:

      connection.uri=mongodb://localhost:27017/mydb1,mongodb://localhost:27017/mydb2
      

   2. En la configuración del conector, provee una propiedad collection que corresponda a la colección de bases de datos de MongoDB que deseas conectar con el tema de Kafka. Por ejemplo:

      collection=mycollection
      

   3. Configura la propiedad topics para especificar el tema de Kafka que deseas conectar con las bases de datos de MongoDB. Por ejemplo:

      topics=myTopic
      

   Una vez que has configurado todo, inicia el conector ejecutando el siguiente comando:

   bin/connect-standalone.sh config/connect-standalone.properties config/mongo-source.properties
   

   Con la configuración anterior, el conector creará un tema de Kafka llamado myTopic, y leerá datos de mydb1.mycollection y mydb2.mycollection y los escribirá en el tema de Kafka myTopic.

   En resumen, al proporcionar múltiples URI’s y bases de datos de MongoDB en la configuración del conector, y un solo tema de Kafka, puedes conectar fácilmente múltiples bases de datos de MongoDB a un tema de Kafka usando MongoSourceConnector.

Comments are closed.