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 mudança. O nome do tópico de destino é composto topic.prefix pelo valor seguido pelos nomes do banco de dados e da coleção, separados pelo valor especificado na topic.separator propriedade .

Para saber mais, consulte o exemplo em Prefixo de nomenclatura de tópicos.

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 topic.suffix valor, separado pelo valor especificado na topic.separator propriedade.

Para saber mais, consulte o exemplo em Sufixo de nomenclatura de tópicos.

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

topic.namespace.map

Tipo: string

Descrição:
especifica um mapeamento JSON entre namespaces de documento de change stream e nomes de tópicos.

Você pode utilizar a topic.namespace.map propriedade para especificar mapeamentos complexos. Essa propriedade oferece suporte à correspondência de caracteres regulares e curingas.

Para saber mais sobre esses comportamentos e ver exemplos, consulte Mapa de namespace de tópicos.

Padrão: ""
Valores aceitos: um objeto JSON válido

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 a alteração de documentos de fluxo 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=-

IMPORTANTE: quando você usar a topic.separator propriedade , observe que ela não afeta como você define a topic.namespace.map propriedade . A topic.namespace.map propriedade utiliza namespace MongoDB que você deve sempre especificar com um . caractere para separar o nome do banco de dados e da coleção.

Padrão: "."
Valores aceitos: uma 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.