Migrar desde Kafka Connect MongoDB

Utilice esta guía para migrar sus implementaciones de Kafka desde la comunidad creada Conexión de Kafka a MongoDBConector de sumidero al conector oficial de MongoDB Kafka.

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

Nota

Atlas Stream Processing proporciona herramientas nativas de MongoDB para procesar continuamente datos de transmisión, validar esquemas y materializar vistas en colecciones de bases de datos Atlas o temas de Apache Kafka.

Para obtener más información sobre el procesamiento de secuencias Atlas, consulte Procesamiento de secuencias Atlas.

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.
Reemplace su configuración connector.class con la clase de conector de receptor MongoDB Kafka.
```
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.
Elimine la document.id.strategies configuración si existe. Si el valor de esta configuración hace referencia a estrategias personalizadas, muévalas a la document.id.strategy configuración. Consulte la sección "Actualizar clases personalizadas" para descubrir qué cambios debe realizar en sus clases personalizadas.
Reemplace cualquier nombre de propiedad que utilice para especificar anulaciones por tema o colección que contengan el prefijo mongodb.collection con la clave equivalente en Conector de sumidero Configuración de tema de Kafka Propiedades del tema.

Actualizar clases personalizadas

Si utiliza alguna clase personalizada en su implementación del conector de receptor de Kafka Connect, realice los siguientes cambios antes de agregarla a su implementación del conector de Kafka de MongoDB:

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.
Actualice las clases de estrategia del conector de 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 postprocesador

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