Overview
Importante
Las propiedades copy.existing* están obsoletas
A partir de la versión 1.9 del conector Kafka de MongoDB, copy.existing* Las propiedades están obsoletas y podrían eliminarse en una versión futura. Debe usar las propiedades startup.mode* para configurar la función de copia existente. Para obtener más información sobre la configuración de startup.mode*, consulte
Propiedades de inicio.
Utilice las siguientes configuraciones para habilitar la función de copia existente que convierte las colecciones de MongoDB en eventos de Change Stream.
Tip
Para ver un ejemplo de la función de copia existente, consulte el Ejemplo de uso de copia de datos existentes.
Para obtener una lista de las configuraciones del conector de origen organizadas por categoría, consulte la guía sobre Propiedades de configuración del conector de origen.
Configuraciones
Nombre | Descripción | |
|---|---|---|
copy.existing | Type: boolean Description: Whether to enable the copy existing feature which converts all
data in a MongoDB collection to Change Stream events and
publishes them on Kafka topics. If MongoDB changes the source
collection data after the connector starts the copy process, the
connector creates events for the changes after it completes the copy
process. Si algún sistema modifica los datos de la base de datos mientras el conector de origen convierte los datos existentes, MongoDB puede generar eventos de flujo de cambios duplicados para reflejar los cambios más recientes. Dado que los eventos de flujo de cambios en los que se basa la copia de datos son idempotentes, los datos copiados son consistentes. Default: falseAccepted Values: true or false | |
copy.existing.namespace.regex | Type: string Description: Regular expression the connector uses to match namespaces from
which to copy data. A namespace describes the MongoDB database name
and collection separated by a period (for example, databaseName.collectionName).EjemploEn el siguiente ejemplo, la configuración de expresión regular coincide con las colecciones que comienzan con "página" en la base de datos El carácter "" del ejemplo anterior escapa al carácter "." que le sigue en la expresión regular. Para más información sobre cómo crear expresiones regulares, consulte la documentación de la API de Java sobre patrones. Default: ""Accepted Values: A valid regular expression | |
copy.existing.pipeline | Type: string Description: An array of pipeline operations
the connector runs when copying existing data. You can use this
setting to filter the source collection and improve the use of
indexes in the copying process. EjemploEl siguiente ejemplo muestra cómo se puede utilizar el operador de agregación $match para indicar al conector que copie solo los documentos que contengan un Default: []Accepted Values: Valid aggregation pipeline stages | |
copy.existing.max.threads | Type: int Description: The maximum number of threads the connector can use to copy data. Default: number of processors available in the environment Accepted Values: An integer | |
copy.existing.queue.size | Type: int Description: The size of the queue the connector can use when copying data. Default: 16000Accepted Values: An integer | |
copy.existing.allow.disk.use | Type: boolean Description: When set to true, the connector uses temporary disk storage
for the copy existing aggregation.Default: true |