Página inicial do Docs → Desenvolver aplicações → MongoDB Kafka Connector

Alterar propriedades do stream

Nesta página

Visão geral

Configurações

Visão geral

Use as definições de configuração a seguir para especificar pipelines de agregação para fluxos de mudança e preferências de leitura para cursores de fluxo de mudança ao trabalhar com o conector de origem MongoDB Kafka.

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

gasoduto

Tipo: string

Descrição:
Uma array de pipelines de agregação para execução em seu fluxo de mudança. Você deve definir essa configuração para o documento de evento de fluxo de alterações, não para o campo fullDocument.

Exemplo

[{"$match": { "$and": [{"operationType": "insert"}, {"fullDocument.eventId": 1404 }] } }]

Dica

Exemplos adicionais

Padrão: "[]"

Valores aceitos: estágio de pipeline de agregação válido

change.stream.full.document

Tipo: string

Descrição:
Determina quais valores seu change stream retorna nas operações de atualização.
A configuração padrão retorna as diferenças entre o documento original e o documento atualizado.
A configuração updateLookup retorna as diferenças entre o documento original e o documento atualizado, bem como uma cópia de todo o documento atualizado em um ponto no tempo após a atualização.
A configuração whenAvailable retorna o documento atualizado, se disponível.
A configuração required retorna o documento atualizado e levanta um erro se ele não estiver disponível.

Dica

Para obter mais informações sobre como essa opção de change stream funciona, consulte o guia do manual do servidor MongoDB em Pesquisar documento completo para operações de atualização.

Padrão: ""
Valores aceitos: "", "updateLookup", "whenAvailable" ou "required"

change.stream.full.document.before.change

Tipo: string

Descrição:
Configura a pré-imagem do documento que seu fluxo de alterações retorna nas operações de atualização. A pré-imagem não está disponível para registros de origem publicados durante a cópia de dados existentes, e a configuração da pré-imagem não tem efeito sobre a cópia.

Dica

Para saber como configurar uma coleção para habilitar pré-imagens, consulte a entrada manual do servidor em pré e pós-imagens.

A configuração padrão suprime a pré-imagem do documento.
A configuração whenAvailable retorna a pré-imagem do documento se ela estiver disponível, antes de ser substituída, atualizada ou excluída.
A configuração required retorna a pré-imagem do documento e gera um erro se ela não estiver disponível.

Padrão: ""
Valores aceitos: "" ou "whenAvailable" ou "required"

publish.full.document.only

Tipo: booleano

Descrição:
Se deve retornar somente o campo fullDocument do documento de evento do fluxo de alterações produzido por qualquer evento de atualização. O campo fullDocument contém a versão mais atual do documento atualizado. Para saber mais sobre o campo fullDocument consulte o Evento update no manual do Servidor.

Quando definido como true, o conector substitui a configuração change.stream.full.document e a define como updateLookup para que o campo fullDocument contenha documentos atualizados.

Padrão: false

Valores aceitos: true ou false

publish.full.document.only.tombstone.on.delete

Tipo: booleano

Descrição:
Se os eventos da lápide devem ser devolvidos quando os documentos são excluídos. Os eventos Tombstone contêm as chaves dos documentos excluídos com valores null. Essa configuração se aplica somente quando publish.full.document.only é true.

Padrão: false

Valores aceitos: true ou false

change.stream.document.key.as.key

Tipo: booleano

Descrição:
Se a chave do documento deve ser usada para a chave do registro de origem se a chave do documento estiver presente.

Quando definido como true, o conector adiciona chaves dos documentos excluídos aos eventos de marca para exclusão. Quando definido como false, o conector usa o token de continuação como chave de origem para os eventos de marca para exclusão.

Padrão: true

Valores aceitos: true ou false

Agrupamento

Tipo: string

Descrição:
Um JSON documento de agrupamento que especifica as regras de ordenação específicas do idioma que o MongoDB aplica aos documentos retornados pelo fluxo de alterações.

Padrão: ""
Valores aceitos: um documento JSON de agrupamento válido

batch.size

Tipo: int

Descrição:
O tamanho do lote do cursor do change stream.

Padrão: 0
Valores aceitos: um número inteiro

poll.await.time.ms

Tipo: longo

Descrição:
A quantidade máxima de tempo em milissegundos que o servidor aguarda por novas alterações de dados para relatar ao cursor do fluxo de alterações antes de retornar um lote vazio.

Padrão: 5000
Valores aceitos: um número inteiro

poll.max.batch.size

Tipo: int

Descrição:
Número máximo de documentos a serem lidos em um único lote ao pesquisar um cursor de fluxo de alteração para novos dados. Você pode usar essa configuração para limitar a quantidade de dados armazenados internamente no conector.

Padrão: 1000
Valores aceitos: um número inteiro

← Propriedades do tópico Kafka

Propriedades do Formato de Saída →