Menu Docs
Página inicial do Docs
/
MongoDB Kafka Connector
/ /

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

Nesta página

  • Visão geral
  • WriteModel
  • Excluir modelo de gravação
  • Strategies

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.

Defina a propriedade de configuração writemodel.strategy para especificar como o connector do coletor grava dados quando recebe um registro de 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çãoEstratégias desta página. Você pode especificar uma estratégia definindo a seguinte configuração:

writemodel.strategy=<a write model strategy>

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.

Nome
Descrição
DefaultWriteModelStrategy

Description:
This strategy uses the ReplaceOneDefaultStrategy by default, and the InsertOneDefaultStrategy if you set the timeseries.timefield option.

This is the default value value for the writemodel.strategy configuration property.
InsertOneDefaultStrategy

Description:
Insert each sink record into MongoDB as a document.
To specify this strategy, set the configuration property to the following class name:
com.mongodb.kafka.connect.sink.writemodel.strategy.InsertOneDefaultStrategy
ReplaceOneDefaultStrategy

Description:
Replaces at most one document in MongoDB that matches a sink record by the _id field. If no documents match, the connector inserts the sink record as a new document.
To specify this strategy, set the configuration property to the following class name:
com.mongodb.kafka.connect.sink.writemodel.strategy.ReplaceOneDefaultStrategy
ReplaceOneBusinessKeyStrategy

Description:
Replaces at most one document that matches a sink record by a specified business key. If no documents match, the connector inserts the sink record as a new document.
To specify this strategy, set the configuration property to the following class name:
com.mongodb.kafka.connect.sink.writemodel.strategy.ReplaceOneBusinessKeyStrategy
To see an example showing how to use this strategy, see our guide on write model strategies.
DeleteOneDefaultStrategy

Description:
Deletes at most one document that matches your sink connector's key structure by the _id field only when the document contains a null value structure.

This is the default value for the delete.writemodel.strategy configuration property.

This strategy is set as the default value of the writemodel.strategy property when you set mongodb.delete.on.null.values=true.
To specify this strategy, set the configuration property to the following class name:
com.mongodb.kafka.connect.sink.writemodel.strategy.DeleteOneDefaultStrategy
DeleteOneBusinessKeyStrategy

Description:
Deletes at most one MongoDB document that matches a sink record by a business key.
To specify this strategy, set the configuration property to the following class name:
com.mongodb.kafka.connect.sink.writemodel.strategy.DeleteOneBusinessKeyStrategy
To see an example showing how to use this strategy, see our guide on write model strategies.
UpdateOneDefaultStrategy

Description:
Updates at most one document in MongoDB that matches a sink record by the _id field. If no documents match, the connector inserts the sink record as a new document.
To specify this strategy, set the configuration property to the following class name:
com.mongodb.kafka.connect.sink.writemodel.strategy.UpdateOneDefaultStrategy
UpdateOneTimestampsStrategy

Description:
Add _insertedTS (inserted timestamp) and _modifiedTS (modified timestamp) fields into documents.
To specify this strategy, set the configuration property to the following class name:
com.mongodb.kafka.connect.sink.writemodel.strategy.UpdateOneTimestampsStrategy
To see an example showing how to use this strategy, see our guide on write model strategies.
UpdateOneBusinessKeyTimestampStrategy

Description:
Add _insertedTS (inserted timestamp) and _modifiedTS (modified timestamp) fields into documents that match a business key.
To specify this strategy, set the configuration property to the following class name:
com.mongodb.kafka.connect.sink.writemodel.strategy.UpdateOneBusinessKeyTimestampStrategy

Voltar

Estratégia de ID