Propriedades do tópico Kafka para o conector de origem

topic.prefix

Tipo: string

Descrição:
Especifica a primeira parte do nome do tópico Kafka de destino na qual o conector publica eventos de fluxo de alterações. O nome do tópico de destino é composto pelo valor topic.prefix seguido pelos nomes do banco de dados e da coleção, separados pelo valor especificado na propriedade topic.separator .

Para aprender mais, consulte o exemplo em Prefixo de nomenclatura de tópico.

Padrão: ""
Valores aceitos: uma string composta de caracteres alfanuméricos ASCII, incluindo ".", "-" e "_"

topic.suffix

Tipo: string

Descrição:
Especifica a última parte do nome do tópico Kafka de destino para o qual o conector publica eventos de fluxo de alteração. O nome do tópico de destino é composto dos nomes do banco de dados e da coleção seguidos pelo valor topic.suffix, separado pelo valor especificado na propriedade topic.separator.

Para aprender mais, veja o exemplo em Sufixo de Nomenclatura de Tópico.

Padrão: ""
Valores aceitos: uma string composta de caracteres alfanuméricos ASCII, incluindo ".", "-" e "_"

topic.namespace.map

Type: string

Description:
Specifies a JSON mapping between change stream document namespaces and topic names.

You can use to topic.namespace.map property to specify complex mappings. This property supports regex and wildcard matching.

To learn more about these behaviors and view examples, see Topic Namespace Map.

Default: ""
Accepted Values: A valid JSON object

topic.separator

Tipo: string

Descrição:
Especifica a string que o conector utiliza para concatenar os valores utilizados para criar o nome do seu tópico. O conector publica registros em um tópico com um nome formado pela concatenação dos valores dos seguintes campos na seguinte ordem:

1. topic.prefix

2. database

3. collection

4. topic.suffix

Por exemplo, a seguinte configuração instrui o conector a publicar documentos de fluxo de alterações da coleção coll do banco de dados db para o tópico prefix-db-coll:

topic.prefix=prefix
database=db
collection=coll
topic.separator=-

IMPORTANT: When you use the topic.separator property, note that it doesn't affect how you define the topic.namespace.map property. The topic.namespace.map property uses MongoDB namespaces which you must always specify with a . character to separate the database and collection name.

Default: "."
Accepted Values: A string

topic.mapper

Tipo: string

Descrição:
A classe Java que define sua lógica de mapeamento de tópico personalizada.

Padrão: com.mongodb.kafka.connect.source.topic.mapping.DefaultTopicMapper
Valores aceitos: nome de classe completa válido de uma implementação da classe TopicMapper.