Propiedades de sobrescritura de temas

Overview

Utilice las siguientes configuraciones del conector de receptor MongoDB Kafka para anular las configuraciones de propiedades globales o predeterminadas para temas específicos.

Para obtener una lista de las configuraciones del conector del fregadero organizadas por categoría, consulte la guía en 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 recepción para recibir datos de temas específicos. El siguiente ejemplo de configuración muestra cómo definir las opciones de 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 del receptor realiza lo siguiente para los datos consumidos desde topicA:

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

Para obtener un ejemplo de cómo configurar el Proyector de lista de bloques, consulte la guía de Postprocesadores.

Volver

Escribir la estrategia del modelo

Captura de datos modificados