/ /

Conector de coletor

Propriedades de configuração

Página inicial do Docs

Ferramentas

Conector Kafka

Conector de coletor

Propriedades de configuração

Estratégias do modelo de gravação do conector do coletor

Visão geral

Você pode definir propriedades de configuração para especificar como o de MongoDB Kafka coletor do connector grava dados no MongoDB. As seções a seguir descrevem as propriedades de configuração que você pode definir para personalizar este comportamento.

WriteModel

Configure a propriedade de configuração writemodel.strategy para especificar como o connector do coletor grava dados quando recebe um registro do coletor.

Você pode definir o valor de writemodel.strategy para qualquer um dos nomes de classe totalmente qualificados das estratégias de modelo de gravação descritas na seção Estratégias desta página. Você pode especificar uma estratégia definindo a seguinte configuração:

writemodel.strategy=<a write model strategy>

Excluir modelo de gravação

Configure a propriedade de configuração delete.writemodel.strategy para especificar como o connector do coletor grava dados quando recebe um evento de marca para exclusão. Um evento de marca de exclusão é um registro que contém uma chave, mas nenhum valor, o que significa um registro excluído.

Você pode definir o valor de delete.writemodel.strategy para qualquer um dos nomes de classe totalmente qualificados das estratégias de modelo de gravação descritas na seção Estratégias desta página. Você pode especificar uma estratégia definindo a seguinte configuração:

delete.writemodel.strategy=<a write model strategy>

Para obter uma lista de definições de configuração do conector de coletor organizadas por categoria, consulte o guia sobre Propriedades de configuração do Connector de coletor.

Strategies

Nome

Descrição

DefaultWriteModelStrategy

Descrição:
Essa estratégia usa o ReplaceOneDefaultStrategy por padrão e o InsertOneDefaultStrategy se você definir a timeseries.timefield opção.

Este é o valor padrão para a writemodel.strategy propriedade de configuração.

InsertOneDefaultStrategy

Descrição:
Insira cada registro de coletor no MongoDB como um documento.
Para especificar esta estratégia, defina a propriedade de configuração para o seguinte nome de classe :

com.mongodb.kafka.connect.sink.writemodel.strategy.InsertOneDefaultStrategy

ReplaceOneDefaultStrategy

Descrição:
Substitui, no máximo, um documento no MongoDB que corresponda a um registro de coletor pelo _id campo. Se nenhum documento corresponder, o conector inserirá o registro de coletor como um novo documento.
Para especificar esta estratégia, defina a propriedade de configuração para o seguinte nome de classe :

com.mongodb.kafka.connect.sink.writemodel.strategy.ReplaceOneDefaultStrategy

Substituir uma estratégia-chave de negócio

Descrição:
Substitui no máximo um documento que corresponda a um registro de coletor por uma chave de negócios especificada. Se nenhum documento corresponder, o conector inserirá o registro de coletor como um novo documento.
Para especificar esta estratégia, defina a propriedade de configuração para o seguinte nome de classe :

com.mongodb.kafka.connect.sink.writemodel.strategy.ReplaceOneBusinessKeyStrategy

Para ver um exemplo mostrando como usar essa estratégia, consulte nosso guia sobre estratégias de modelo de gravação.

DeleteOneDefaultStrategy

Descrição:
Exclui no máximo um documento que corresponda à estrutura de chave do conector do coletor pelo _id campo somente quando o documento contiver uma estrutura de valor nulo.

Este é o valor padrão para a delete.writemodel.strategy propriedade de configuração.

Essa estratégia é definida como o valor padrão da writemodel.strategy propriedade quando você delete.on.null.values=true define.
Para especificar esta estratégia, defina a propriedade de configuração para o seguinte nome de classe :

com.mongodb.kafka.connect.sink.writemodel.strategy.DeleteOneDefaultStrategy

Excluir uma estratégia de chave de negócios

Descrição:
Exclui no máximo um documento do MongoDB que corresponde a um registro de coletor por uma chave comercial.
Para especificar essa estratégia, defina a propriedade de configuração para o seguinte nome de classe:

com.mongodb.kafka.connect.sink.writemodel.strategy.DeleteOneBusinessKeyStrategy

Para ver um exemplo mostrando como usar essa estratégia, consulte nosso guia sobre estratégias de modelo de gravação.

UpdateOneDefaultStrategy

Descrição:
Atualiza no máximo um documento no MongoDB que corresponde a um registro de coletor pelo _id campo. Se nenhum documento corresponder, o conector inserirá o registro de coletor como um novo documento.
Para especificar esta estratégia, defina a propriedade de configuração para o seguinte nome de classe :

com.mongodb.kafka.connect.sink.writemodel.strategy.UpdateOneDefaultStrategy

Atualizar estratégia de carimbos de data/hora

Descrição:
Adicione _insertedTS campos (carimbo de data/hora inserido) e _modifiedTS (carimbo de data/hora modificado) em documentos.
Para especificar esta estratégia, defina a propriedade de configuração para o seguinte nome de classe :

com.mongodb.kafka.connect.sink.writemodel.strategy.UpdateOneTimestampsStrategy

Para ver um exemplo mostrando como usar essa estratégia, consulte nosso guia sobre estratégias de modelo de gravação.

UpdateOne BusinessKeyTimestampStrategy

Descrição:
Adicione _insertedTS campos (carimbo de data/hora inserido) e _modifiedTS (carimbo de data/hora modificado) em documentos que correspondam a uma chave de negócios.
Para especificar esta estratégia, defina a propriedade de configuração para o seguinte nome de classe :

com.mongodb.kafka.connect.sink.writemodel.strategy.UpdateOneBusinessKeyTimestampStrategy

Voltar

Estratégia de ID

Substituição de tópico