Propriedades de substituição de tópico

Visão geral

Use as seguintes definições de configuração do conector do coletor do MongoDB Kafka para substituir as configurações de propriedade globais ou padrão para tópicos específicos.

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
topic.override.<topicName>.<propertyName>	Tipo: string Descrição: Especifique um tópico e nome de propriedade para substituir a configuração de propriedade global ou padrão correspondente. Por exemplo, a `topic.override.foo.collection=bar` configuração instrui o conector do coletor a armazenar dados do `foo` tópico na `bar` collection . Você pode especificar qualquer definição de configuração válida no `<propertyName>` segmento por tópico, exceto `connection.uri` e.`topics` Padrão: `""` Valores aceitos: valores aceitos específicos para a propriedade substituída

Nome

Descrição

topic.override.<topicName>.<propertyName>

Tipo: string

Descrição:
Especifique um tópico e nome de propriedade para substituir a configuração de propriedade global ou padrão correspondente.

Por exemplo, a topic.override.foo.collection=bar configuração instrui
o conector do coletor a armazenar dados do foo tópico na bar
collection .

Você pode especificar qualquer definição de configuração válida no
<propertyName> segmento por tópico, exceto
connection.uri e.topics

Padrão: ""
Valores aceitos: valores aceitos específicos para a propriedade substituída

Exemplo

Você pode substituir o connector do coletor para coletar dados de tópicos específicos. O exemplo de configuração a seguir mostra como você pode definir definições de configuração para um tópico chamado topicA:

topic.override.topicA.collection=collectionA
topic.override.topicA.max.batch.size=100
topic.override.topicA.document.id.strategy=com.mongodb.kafka.connect.sink.processor.id.strategy.UuidStrategy
topic.override.topicA.post.processor.chain=com.mongodb.kafka.connect.sink.processor.DocumentIdAdder,com.mongodb.kafka.connect.sink.processor.BlockListValueProjector
topic.override.topicA.value.projection.type=BlockList
topic.override.topicA.value.projection.list=k2,k4

Após aplicar estas definições de configuração, o connector de pia executa o seguinte para dados consumidos do topicA:

Grave documento na MongoDB collection collectionA em lote de até 100.
Gere um valor UUID para cada novo documento e escreva-o no campo _id .
Omita os campos k2 e k4 da projeção de valor utilizando o tipo de projeção BlockList .

Para obter um exemplo de como configurar o projetor da lista de bloqueios, consulte o guia de pós-processadores .

Voltar

Estratégia do modelo de escrita

Alterar captura de dados