/ /

Conector de coletor

Propriedades de configuração

Página inicial do Docs

Ferramentas

Conector Kafka

Conector de coletor

Propriedades de configuração

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

Tipo: string

Descrição:
o nome da classe totalmente qualificado da classe que especifica em qual banco de dados ou collection coletar os dados. O padrão DefaultNamespaceMapper utiliza valores especificados nas database collection propriedades e.

O conector inclui uma classe alternativa para especificar o
banco de dados e a coleção chamados.FieldPathNamespaceMapper
Consulte Configurações do FieldPathNamespaceMapper para obter
mais informações.

Padrão:

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 no qual o conector de pia grava.

Valores aceitos: um nome de banco de dados MongoDB

collection

Tipo: string

Descrição:
o nome da collection MongoDB na qual o conector de pia grava. Se o conector do coletor 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 escrever.
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 escrever.
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 escrever.
namespace.mapper.value.collection.field	Tipo: string Descrição: o nome do campo do documento de valor que especifica o nome da collection na qual escrever.
namespace.mapper.error.if.invalid	Tipo: boolean Descrição: Se deve lançar uma exceção quando o documento não tiver o campo mapeado ou tiver um tipo de BSON inválido. Quando definido `true` como, o conector não processa documentos que não tenham o campo mapeado ou que contenham um tipo de BSON inválido. O conector pode interromper ou ignorar o processamento, dependendo das definições de configuração de tratamento de erros relacionadas. Quando definido `false` como, se um documento não tiver o campo mapeado ou se tiver um tipo de BSON inválido, o conector assumirá como padrão 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