/ /

Connector de sumidero

Propiedades de configuración

Docs Home

Herramientas

Kafka Connector

Connector de sumidero

Propiedades de configuración

Estrategias de modelo de escritura de conector de sumidero

Overview

Puedes establecer propiedades de configuración para especificar cómo el conector sink de Kafka de MongoDB escribe datos en MongoDB. Las siguientes secciones describen las propiedades de configuración que se pueden configurar para personalizar este comportamiento.

Modelo de guardar

Establece la propiedad de configuración writemodel.strategy para especificar cómo el conector sink escribe datos cuando recibe un registro sink.

Puede establecer el valor de writemodel.strategy en cualquiera de los nombres de clase totalmente calificados de las estrategias del modelo de guardado descritas en la sección Estrategias de esta página. Puede especificar una estrategia configurando lo siguiente:

writemodel.strategy=<a write model strategy>

Eliminar modelo guardar

Establece la propiedad de configuración delete.writemodel.strategy para especificar cómo el conector del destino escribe datos al recibir un evento tombstone. Un evento tombstone es un registro que contiene una clave pero sin valor, lo que indica un registro borrado.

Puede establecer el valor de delete.writemodel.strategy en cualquiera de los nombres de clase totalmente calificados de las estrategias del modelo de guardado descritas en la sección Estrategias de esta página. Puede especificar una estrategia configurando lo siguiente:

delete.writemodel.strategy=<a write model strategy>

Para una lista de configuraciones de conectores sumideros organizada por categoría, consulta la guía sobre Propiedades de configuración de conectores sumideros.

Strategies

Nombre

Descripción

DefaultWriteModelStrategy

descripción:
Esta estrategia utiliza el ReplaceOneDefaultStrategy por defecto y el InsertOneDefaultStrategy si establece la opción timeseries.timefield.

Este es el valor por defecto para la propiedad de configuración writemodel.strategy.

InsertOneDefaultStrategy

descripción:
Inserte cada registro de receptor en MongoDB como un documento.
Para especificar esta estrategia, establezca la propiedad de configuración en el siguiente nombre de clase:

com.mongodb.kafka.connect.sink.writemodel.strategy.InsertOneDefaultStrategy

ReplaceOneDefaultStrategy

descripción:
Reemplaza como máximo un documento en MongoDB que coincida con un registro de receptor por el campo _id. Si no hay documentos que coincidan, el conector inserta el registro del receptor como un nuevo documento.
Para especificar esta estrategia, establezca la propiedad de configuración en el siguiente nombre de clase:

com.mongodb.kafka.connect.sink.writemodel.strategy.ReplaceOneDefaultStrategy

Reemplazar una Estrategia de clave comercial

descripción:
Reemplaza como máximo un documento que coincide con un registro de receptor mediante una clave comercial especificada. Si no hay documentos que coincidan, el conector inserta el registro del receptor como un nuevo documento.
Para especificar esta estrategia, establezca la propiedad de configuración en el siguiente nombre de clase:

com.mongodb.kafka.connect.sink.writemodel.strategy.ReplaceOneBusinessKeyStrategy

Para ver un ejemplo que muestra cómo utilizar esta estrategia, consulta nuestra guía sobre estrategias de modelos de escritura.

DeleteOneDefaultStrategy

descripción:
Borra como máximo un documento que coincida con la estructura de clave de su conector de receptor solo por el campo _id cuando el documento contenga una estructura de valor nulo.

Este es el valor por defecto de la propiedad de configuración delete.writemodel.strategy.

Esta estrategia se establece como el valor por defecto de la propiedad writemodel.strategy cuando se establece delete.on.null.values=true.
Para especificar esta estrategia, establezca la propiedad de configuración en el siguiente nombre de clase:

com.mongodb.kafka.connect.sink.writemodel.strategy.DeleteOneDefaultStrategy

DeleteOneBusinessKeyStrategy

descripción:
Borra como máximo un documento de MongoDB que coincida con un registro de receptor mediante una clave comercial. Esta estrategia requiere un valueDoc para la generación de claves. Para aprovechar el PartialKeyStrategy para la generación de claves, utilice el DeleteOneTombstoneBusinessKeyStrategy.

Para especificar esta estrategia, establezca la propiedad de configuración en el siguiente nombre de clase:

com.mongodb.kafka.connect.sink.writemodel.strategy.DeleteOneBusinessKeyStrategy

Para ver un ejemplo que muestra cómo utilizar esta estrategia, consulta nuestra guía sobre estrategias de modelos de escritura.

DeleteOneTombstoneBusinessKeyStrategy

descripción:
Borra como máximo un documento de MongoDB que coincida con un registro de receptor mediante una clave comercial. Esta estrategia aprovecha el PartialKeyStrategy para crear la clave utilizada para la eliminación.

Para especificar esta estrategia, establezca la propiedad de configuración en el siguiente nombre de clase:

com.mongodb.kafka.connect.sink.writemodel.strategy.DeleteOneTombstoneBusinessKeyStrategy

UpdateOneDefaultStrategy

descripción:
Actualiza como máximo un documento en MongoDB que coincida con un registro de receptor por el campo _id. Si no hay documentos que coincidan, el conector inserta el registro del receptor como un nuevo documento.
Para especificar esta estrategia, establezca la propiedad de configuración en el siguiente nombre de clase:

com.mongodb.kafka.connect.sink.writemodel.strategy.UpdateOneDefaultStrategy

UpdateOneTimestampsStrategy

descripción:
Agregue los campos _insertedTS (marca de tiempo insertada) y _modifiedTS (marca de tiempo modificada) en los documentos.
Para especificar esta estrategia, establezca la propiedad de configuración en el siguiente nombre de clase:

com.mongodb.kafka.connect.sink.writemodel.strategy.UpdateOneTimestampsStrategy

Para ver un ejemplo que muestra cómo utilizar esta estrategia, consulta nuestra guía sobre estrategias de modelos de escritura.

UpdateOneBusinessKeyTimestampStrategy

descripción:
Agregue los campos _insertedTS (marca de tiempo insertada) y _modifiedTS (marca de tiempo modificada) en los documentos que coincidan con una llave comercial.
Para especificar esta estrategia, establezca la propiedad de configuración en el siguiente nombre de clase:

com.mongodb.kafka.connect.sink.writemodel.strategy.UpdateOneBusinessKeyTimestampStrategy

Volver

Estrategia Id

Anulación del tema