Migrar desde Kafka Connect MongoDB

Usa esta guía para migrar tus implementaciones de Kafka del creado por la comunidad Kafka Connect MongoDB conector sumidero al MongoDB official Kafka Connector.

Las siguientes secciones enumeran los cambios que debe realizar en los ajustes de configuración del conector sink de Kafka Connect y en las clases personalizadas para la transición al conector sink de MongoDB Kafka.

Actualizar configuraciones de configuración

Realiza los siguientes cambios en la configuración de tu implementación de Kafka Connect antes de utilizarlos con tu implementación de tu MongoDB Kafka Connector:

Reemplaza los valores que incluyen el paquete at.grahsl.kafka.connect.mongodb con el paquete com.mongodb.kafka.connect.
Sustituye tu configuración de connector.class por la clase de conector sink Kafka de MongoDB.
```
connector.class=com.mongodb.kafka.connect.MongoSinkConnector
```
Elimina el prefijo mongodb. de los nombres de tus propiedades de Kafka Connect. Por ejemplo, cambia mongodb.connection.uri a connection.uri.
Remueve la configuración de document.id.strategies si existe. Si el valor de este ajuste hace referencia a estrategias personalizadas, muévelas al ajuste document.id.strategy. Lee la sección Actualizar clases personalizadas para descubrir qué cambios debes realizar en tus clases personalizadas.
Reemplace cualquier nombre de propiedad que utilice para especificar anulaciones por tema o colección que contengan el prefijo mongodb.collection por la clave equivalente en conector de sumidero de propiedades de configuración del tema de Kafka del tema.

Actualizar Clases Personalizadas

Si utiliza alguna clase personalizada en su implementación del conector sumidero de Kafka Connect, realice los siguientes cambios en ellas antes de añadirlas a la implementación de su conector MongoDB Kafka:

Reemplaza las importaciones que incluyan at.grahsl.kafka.connect.mongodb con com.mongodb.kafka.connect.
Reemplaza las referencias a la clase MongoDbSinkConnector por la clase MongoSinkConnector.
Actualiza las clases de estrategia del conector sumidero personalizado para implementar la interfaz com.mongodb.kafka.connect.sink.processor.id.strategy.IdStrategy.
Actualiza las referencias a la clase MongoDbSinkConnectorConfig. En el MongoDB Kafka Connector, la lógica de esa clase se divide en las siguientes clases:
- MongoSinkConfig
- MongoSinkTopicConfig

Actualizar subclases del procesador posterior

Si tienes clases que sean subclases de un postprocesador en la implementación de tu conector de Kafka Connect, actualiza los métodos que sobrescriban a los de la clase PostProcessor de Kafka Connect para que coincidan con las firmas de método del conector MongoDB Kafka Clase PostProcessor.

Volver

Monitoring

Solución de problemas