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: string Descripción: Especifica un tema y un nombre de propiedad para anular la configuración de propiedad global o por defecto correspondiente. Por ejemplo, la `topic.override.foo.collection=bar` configuración indica al conector de receptor que almacene datos del `foo` tema en la `bar` colección. Puedes especificar cualquier configuración válida en el `<propertyName>` segmento por tema, excepto `connection.uri` `topics`y. Por defecto: `""` Valores aceptados: Valores aceptados específicos de la propiedad anulada

Nombre

Descripción

tema.override.<topicName>.<propertyName>

Tipo: string

Descripción:
Especifica un tema y un nombre de propiedad para anular la configuración de propiedad global o por defecto correspondiente.

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

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

Por defecto: ""
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