Copiar propriedades existentes
Nesta página
Visão geral
Importante
As propriedades copy.existing* estão obsoletas
A partir da versão 1.9 do MongoDB Kafka Connector, as propriedades copy.existing* são preteridas e podem ser removidas em uma versão futura. Você deve usar propriedades do startup.mode* para configurar a funcionalidade de cópia existente. Para saber mais sobre as configurações do startup.mode* , consultePropriedades de inicializaçãodo .
Use as seguintes definições de configuração para habilitar o recurso de cópia existente que converte as collection do MongoDB em evento de change stream.
Dica
Veja também:
Para obter um exemplo da funcionalidade de cópia existente, consulte o Exemplo de uso de cópia de dados existentes .
Para obter uma lista de definições de configuração do conector de origem organizadas por categoria, consulte o guia sobre Propriedades de configuração do conector de origem.
Configurações
Nome | Descrição | |
|---|---|---|
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. Se algum sistema alterar os dados no banco de dados enquanto o conector de origem converte dados existentes dele, o MongoDB poderá produzir eventos de fluxo de alterações duplicados para refletir as alterações mais recentes. Como os eventos de fluxo de alterações nos quais a cópia de dados depende são idempotentes, os dados copiados são eventualmente 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).ExemploNo exemplo a seguir, a configuração de expressão regular corresponde às coleção que começam com "page" no banco de dados O caractere "" no exemplo acima escapa do "." caractere que o segue na expressão regular. Para obter mais informações sobre como criar expressões regulares, consulte a documentação da API Java em padrões. 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. ExemploO exemplo seguinte mostra como você pode utilizar o operador de agregação $match para instruir o connector a copiar somente documentos que contêm um campo 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 |