Propriedades de configuração de mapeamento de namespace MongoDB

Visão geral

Use as seguintes definições de configuração para especificar em qual MongoDB database e collection o connector de sink do MongoDB Kafka grava os dados. Você pode utilizar o DefaultNamespaceMapper padrão ou especificar uma classe personalizada.

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.

Configurações

Nome

Descrição

namespace.mapper

Type: string

Description:
The fully-qualified class name of the class that specifies which database or collection in which to sink the data. The default DefaultNamespaceMapper uses values specified in the database and collection properties.

The connector includes an alternative class for specifying the
database and collection called FieldPathNamespaceMapper. See
FieldPathNamespaceMapper Settings
for more information.

Default:

com.mongodb.kafka.connect.sink.namespace.mapping.DefaultNamespaceMapper

Valores aceitos: Um nome de classe Java totalmente qualificado de uma classe que implementa a interface NamespaceMapper .

database

Obrigatório

Tipo: string

Descrição:
O nome do banco de dados MongoDB para o qual o conector de coletor grava.

Valores aceitos: um nome de banco de dados MongoDB

collection

Tipo: string

Descrição:
O nome da coleção MongoDB para a qual o conector de sink grava. Se o conector de sink seguir vários tópicos, esta será a coleção padrão para quaisquer gravações que não sejam especificadas de outra forma.

Padrão: o nome do tópico.

Valores aceitos : Um nome de collection do MongoDB

Configurações do FieldPathNamespaceMapper

Se você configurar o conector de pia para usar o FieldPathNamespaceMapper, poderá especificar qual banco de dados e coleção coletará um documento com base nos valores de campo dos dados.

Para habilitar esse comportamento de mapeamento, defina a propriedade de configuração do conector de pia namespace.mapper como o nome da classe totalmente qualificado, conforme mostrado abaixo:

namespace.mapper=com.mongodb.kafka.connect.sink.namespace.mapping.FieldPathNamespaceMapper

O FieldPathNamespaceMapper exige que você especifique as seguintes configurações:

Uma ou ambas as propriedade de mapeamento para um reconhecimento de data center e collection
Um dos mapeamentos do key ou value para um banco de dados
Um dos mapeamentos key ou value para uma collection

Você pode usar as seguintes configurações para personalizar o comportamento do FieldPathNamespaceMapper:

Nome	Descrição
namespace.mapper.key.database.field	Tipo: string Descrição: O nome do campo de documento chave que especifica o nome do banco de dados no qual gravar.
namespace.mapper.key.collection.field	Tipo: string Descrição: O nome do campo de documento chave que especifica o nome da coleção na qual gravar.
namespace.mapper.value.database.field	Tipo: string Descrição: O nome do campo de documento de valor que especifica o nome do banco de dados no qual gravar.
namespace.mapper.value.collection.field	Tipo: string Descrição: O nome do campo de documento de valor que especifica o nome da coleção na qual gravar.
namespace.mapper.error.if.invalid	Tipo: booleano Descrição: Se deve lançar uma exceção quando o documento não tiver o campo mapeado ou tiver um tipo BSON inválido. Quando definido como `true`, o conector não processa documentos que não têm o campo mapeado ou que contêm um tipo BSON inválido. O conector pode parar ou ignorar o em processamento dependendo das configurações de configuração de tratamento de erros relacionadas. Quando definido como `false`, se um documento não tiver o campo mapeado ou tiver um tipo BSON inválido, o conector padroniza a gravação nas configurações `database` e `collection` especificadas. Padrão: `false` Valores aceitos: `true` ou `false`

Voltar

Conexão do MongoDB

Tópicos de Kafka