Para agentes de IA: um índice de documentação está disponível em https://www.mongodb.com/pt-br/docs/llms.txt — as versões de markdown de todas as páginas estão disponíveis anexando .md a qualquer caminho de URL.
Use as seguintes definições de configuração para configurar a inicialização do conector de origem MongoDB Kafka para converter coleções MongoDB em Alterar eventos de Stream.
Dica
Para obter um exemplo usando a funcionalidade copiar dados existentes, consulte o Exemplo de uso de Copiar dados existentes .
Descrição: especifica como o conector deve ser iniciado quando não houver nenhum deslocamento de origem disponível. A retomada de um change stream requer um token de retomada, que o conector obtém do deslocamento de origem. Se nenhuma compensação de origem estiver disponível, o conector poderá ignorar todos ou alguns dos dados de origem existentes ou poderá, em um primeiro momento, copiar todos os dados de origem existentes e, em seguida, continuar com o processamento de novos dados.
startup.mode=latestSe, o conector ignorará todos os dados de origem existentes.
startup.mode=timestampSe, o conector aciona startup.mode.timestamp.* propriedades. Se nenhuma propriedade estiver configurada, timestamp será equivalente latest a.
startup.mode=copy_existingSe, o conector copia todos os dados de origem existentes para Alterar eventos de Stream. Esta configuração é equivalente à configuração copy.existing=true preterida.
Se algum sistema alterar os dados no banco de dados enquanto o conector de origem converte os dados existentes dele, o MongoDB poderá produzir eventos de fluxo de mudança 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, em conformidade com uma garantia de entrega "pelo menos uma vez".
Descrição: "" Acionado somente se. Especifica o ponto de partida para o fluxo de alteração. Para saber mais sobre como alterar os parâmetros do stream, consulte $changeStream (agregação) no manual do MongoDB . Padrão: Valores aceitos:
Um número inteiro de segundos desde a época no formato decimal (por exemplo, 30)
Um instante no formato ISO-8601 com uma segunda precisão (por exemplo, 1970-01-01T00:00:30Z)
Um carimbo de data/hora JSON no formato JSON estendido canônico (v2) (por exemplo, {"$timestamp": {"t": 30, "i": 0}})
startup.mode.copy.existing.namespace.regex
Tipo: string
Descrição: expressão regular que o conector usa para corresponder aos namespaces dos quais copiar dados. Um namespace descreve o nome do banco de dados MongoDB e a coleção separados por um período (pordatabaseName.collectionName exemplo,).
Por exemplo, a seguinte configuração de expressão regular corresponde às coleção que começam com "page" no stats 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 Padrões na documentação da API Java .
Padrão: "" Valores aceitos: uma expressão regular válida
startup.mode.copy.existing.pipeline
Tipo: string
Descrição: uma array em linha de operações de pipeline que o conector executa ao copiar dados existentes. Você pode usar essa configuração para filtrar a collection de origem e melhorar o uso de índices no processo de cópia.