Overview
Use la siguiente configuración para especificar a qué base de datos y colección de MongoDB su conector de sink de MongoDB Kafka guardar datos. Puedes utilizar el valor por defecto DefaultNamespaceMapper o especificar una clase personalizada.
Para una lista de configuraciones de conectores sumideros organizada por categoría, consulta la guía sobre Propiedades de configuración de conectores sumideros.
Configuraciones
Nombre | Descripción | |
|---|---|---|
namespace.mapper | Tipo: string Valores aceptados: un nombre de clase Java totalmente calificado de una clase que implemente la interfaz | |
database | Requerido | |
Colección | Tipo: string Por defecto: el nombre del tema. Valores aceptados: Un nombre de colección de MongoDB |
Configuración de FieldPathNamespaceMapper
Si configuras tu conector de sumidero para utilizar el FieldPathNamespaceMapper, puedes especificar a qué base de datos y colección enviar un documento en función de los valores de los campos de los datos.
Para habilitar este comportamiento de mapeo, establezca la propiedad de configuración del conector para sumidero namespace.mapper en el nombre de clase completamente calificado como se muestra a continuación:
namespace.mapper=com.mongodb.kafka.connect.sink.namespace.mapping.FieldPathNamespaceMapper
FieldPathNamespaceMapper requiere que especifiques los siguientes ajustes:
Una o ambas propiedades de mapeo a una base de datos y colección
Uno de los mapeos
keyovaluea una base de datosUna de las asignaciones de
keyovaluea una colección
Puedes usar los siguientes ajustes para personalizar el comportamiento del FieldPathNamespaceMapper:
Nombre | Descripción |
|---|---|
namespace.mapper.key.base de datos.campo | Tipo: string |
namespace.mapper.key.colección.campo | Tipo: string |
namespace.mapper.value.base de datos.campo | Tipo: string |
namespace.mapper.value.collection.field | Tipo: string |
error inválido de mapeo de namespace | Tipo: booleano |