Propiedades del tema Kafka para el Connector de origen

Overview

Utilice la siguiente configuración para especificar en qué temas de Kafka debe publicar datos el conector de origen de MongoDB para Kafka.

Para obtener una lista de la configuración del origen del conector organizadas por categoría, consulta la guía Propiedades de configuración del conector de origen.

Configuraciones

Nombre

Descripción

Preámbulo del tema

Type: string

Description:
Specifies the first part of the destination Kafka topic name to which the connector publishes change stream events. The destination topic name is composed of the topic.prefix value followed by the database and collection names, separated by the value specified in the topic.separator property.

To learn more, see the example in Topic Naming Prefix.

Default: ""
Accepted Values: A string composed of ASCII alphanumeric characters including ".", "-", and "_"

tema.suffix

Type: string

Description:
Specifies the last part of the destination Kafka topic name to which the connector publishes change stream events. The destination topic name is composed of the database and collection names followed by the topic.suffix value, separated by the value specified in the topic.separator property.

To learn more, see the example in Topic Naming Suffix.

Default: ""
Accepted Values: A string composed of ASCII alphanumeric characters including ".", "-", and "_"

tema.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

separador de tema

Tipo: cadena

Descripción:
Especifica la cadena que el conector utiliza para concatenar los valores que se usan para crear el nombre del tema. El conector publica registros en un tema con un nombre formado al concatenar los valores de los siguientes campos en el siguiente orden:

topic.prefix
database
collection
topic.suffix

Por ejemplo, la siguiente configuración indica al conector que publique documentos de flujo de cambios de la colección coll de la base de datos db en el tema prefix-db-coll:

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

IMPORTANTE: Cuando utilice la topic.separator propiedad, tenga en cuenta que no afecta a la definición de la propiedad. La propiedad topic.namespace.map utiliza espacios de topic.namespace.map nombres de MongoDB que siempre debe especificar con un . carácter para separar el nombre de la base de datos y la colección.

"."
Valor predeterminado: Valores aceptados: Una cadena

tema.mapper

Tipo: cadena

Descripción:
La clase Java que define su lógica de asignación de temas personalizada.

Predeterminado: com.mongodb.kafka.connect.source.topic.mapping.DefaultTopicMapper
Valores aceptados: Nombre de clase completo válido de una implementación de la clase TopicMapper.