Propiedades de sobrescritura de temas

Overview

Utilice la siguiente configuración del conector de destino de MongoDB Kafka para reemplazar la configuración global o por defecto de propiedades para temas específicos.

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

Configuraciones

Nombre	Descripción
tema.override.<topicName>.<propertyName>	Tipo: cadena Descripción: Especifique un tema y un nombre de propiedad para anular la configuración de propiedad global o predeterminada correspondiente. Por ejemplo, la `topic.override.foo.collection=bar` configuración indica al `foo` conector de `bar` destino que almacene los datos del tema en la colección. Puede especificar cualquier configuración válida en el segmento para cada `<propertyName>` tema, excepto `connection.uri` `topics`y. Predeterminado: `""` Valores aceptados: Valores aceptados específicos de la propiedad anulada.

Nombre

Descripción

tema.override.<topicName>.<propertyName>

Tipo: cadena

Descripción:
Especifique un tema y un nombre de propiedad para anular la configuración de propiedad global o predeterminada correspondiente.

Por ejemplo, la topic.override.foo.collection=bar configuración
indica al foo conector de bar
destino que almacene los datos del tema en la colección.

Puede especificar cualquier configuración válida en el segmento para cada
<propertyName> tema, excepto
connection.uri topicsy.

Predeterminado: ""
Valores aceptados: Valores aceptados específicos de la propiedad anulada.

Ejemplo

Puede anular el conector de sink para transferir datos de temas específicos. El siguiente ejemplo de configuración muestra cómo puedes definir la configuración para un tema llamado topicA:

topic.override.topicA.collection=collectionA
topic.override.topicA.max.batch.size=100
topic.override.topicA.document.id.strategy=com.mongodb.kafka.connect.sink.processor.id.strategy.UuidStrategy
topic.override.topicA.post.processor.chain=com.mongodb.kafka.connect.sink.processor.DocumentIdAdder,com.mongodb.kafka.connect.sink.processor.BlockListValueProjector
topic.override.topicA.value.projection.type=BlockList
topic.override.topicA.value.projection.list=k2,k4

Después de aplicar estos ajustes de configuración, el conector de sink realiza lo siguiente con los datos consumidos de topicA:

Escribe documentos en la colección MongoDB collectionA en lotes de hasta 100.
Genere un valor UUID para cada nuevo documento y escríbalo en el campo _id.
Omitir los campos k2 y k4 de la proyección de valor usando el tipo de proyección BlockList.

Para ver un ejemplo de cómo configurar el proyector de lista de bloqueos, consulte la guía Procesadores posteriores.

Volver

Guardar Estrategia del modelo

Captura de cambio de datos