Overview
Utilice las siguientes configuraciones para especificar en qué temas de Kafka debe publicar datos el conector de origen de MongoDB Kafka.
Para obtener una lista de las configuraciones del conector de origen organizadas por categoría, consulte la guía en Propiedades de configuración del conector de origen.
Configuraciones
Nombre | Descripción | ||||
|---|---|---|---|---|---|
topic.prefix | 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 "_" | ||||
topic.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 "_" | ||||
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 | Type: string Description: Specifies the string the connector uses to concatenate the values used
to create the name of your topic. The connector publishes records to a
topic with a name formed by concatenating the values of the following fields
in the following order:
For example, the following configuration instructs the connector to publish
change stream documents from the coll collection of the
db database to the prefix-db-coll topic: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 | Type: string Description: The Java class that defines your custom topic mapping logic. Default: com.mongodb.kafka.connect.source.topic.mapping.DefaultTopicMapperAccepted Values: Valid full class name of an implementation
of the TopicMapper
class. |