/ /

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 guardar 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 guardar 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 ReplaceOneDefaultStrategy InsertOneDefaultStrategy el timeseries.timefield valor por defecto, y el valor si se selecciona la opción.

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

InsertOneDefaultStrategy

descripción:
Inserta cada registro de destino en MongoDB como un documento.
Para especificar esta estrategia, establece la propiedad de configuración con 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 destino por el _id campo. Si no hay documentos coincidentes, el conector inserta el registro de destino como un nuevo documento.
Para especificar esta estrategia, establezca la propiedad de configuración con 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 coincida con un registro de destino por una clave de negocio específica. Si no hay documentos coincidentes, el conector inserta el registro de destino como un nuevo documento.
Para especificar esta estrategia, establezca la propiedad de configuración con 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:
Elimina como máximo un documento que coincida con la estructura de clave de su conector de destino mediante el _id campo solo cuando el documento contiene una estructura de valor nulo.

Este es el valor predeterminado para la delete.writemodel.strategy propiedad de configuración.

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

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

DeleteOneBusinessKeyStrategy

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

Para especificar esta estrategia, establezca la propiedad de configuración con 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:
Elimina como máximo un documento de MongoDB que coincida con un registro de destino mediante una clave de negocio. Esta estrategia utiliza PartialKeyStrategy el valor para crear la clave utilizada para la eliminación.

Para especificar esta estrategia, establezca la propiedad de configuración con 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 destino mediante el _id campo. Si no hay coincidencias, el conector inserta el registro de destino como un nuevo documento.
Para especificar esta estrategia, establezca la propiedad de configuración con el siguiente nombre de clase:

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

UpdateOneTimestampsStrategy

descripción:
Agregue _insertedTS los campos (marca de tiempo insertada) y _modifiedTS (marca de tiempo modificada) a
los documentos. Para especificar esta estrategia, establezca la propiedad de configuración con 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 _insertedTS los campos (marca de tiempo insertada) y _modifiedTS (marca de tiempo modificada) a los documentos que coincidan con una clave de negocio.
Para especificar esta estrategia, establezca la propiedad de configuración con el siguiente nombre de clase:

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

Volver

Estrategia Id

Anulación del tema