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>

Type: string

Description:
Specify a topic and property name to override the corresponding
global or default property setting.

For example, the topic.override.foo.collection=bar setting instructs
the sink connector to store data from the foo topic in the bar
collection.

You can specify any valid configuration setting in the
<propertyName> segment on a per-topic basis except
connection.uri and topics.

Default:  ""
Accepted Values: Accepted values specific to the overridden property

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