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 la configuración

Realice los siguientes cambios en la configuración de su implementación de Kafka Connect antes de usarlos con su implementación del conector MongoDB Kafka:

Reemplazar valores que incluyan 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 las propiedades de Kafka Connect. Por ejemplo, cambia mongodb.connection.uri por 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:

Reemplace 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.
Actualizar las referencias a la clase MongoDbSinkConnectorConfig. En el conector de MongoDB Kafka, la lógica de esa clase se divide en las siguientes clases:
- MongoSinkConfig
- MongoSinkTopicConfig

Actualizar subclases del procesador posterior

Si tiene clases que subclasifican un postprocesador en su implementación del conector de Kafka Connect, actualice los métodos que anulan los de la clase Kafka Connect PostProcessor para que coincidan con las firmas de método de la clase PostProcessor del conector de MongoDB Kafka.

Volver

Monitoring

Solución de problemas