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 de salida organizadas por categoría, consulte la guía sobre Propiedades de configuración del conector del sumidero.

Configuraciones

Nombre

Descripción

topic.override.<topicName>.<propertyName>

Type: string

Description:
Specify a topic and property name to override the corresponding
global or default property setting.

For example, the topic.override.foo.collection=bar setting instructs
the sink connector to store data from the foo topic in the bar
collection.

You can specify any valid configuration setting in the
<propertyName> segment on a per-topic basis except
connection.uri and topics.

Default:  ""
Accepted Values: Accepted values specific to the overridden property

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

Escribir la estrategia del modelo

Captura de datos modificados