Para agentes de IA: hay un índice de documentación disponible en https://www.mongodb.com/es/docs/llms.txt — versiones en markdown de todas las páginas están disponibles agregando .md a cualquier ruta URL.
Todas las propiedades de configuración del conector Sink
Overview
En esta página, puedes ver todas las propiedades de configuración disponibles para tu conector sink de MongoDB Kafka. Esta página duplica el contenido de las otras páginas de propiedades de configuración del conector de destino.
IMPORTANTE: Para evitar exponer tus credenciales de autenticación en tu configuración de connection.uri, utiliza un ConfigProvider y establece los parámetros de configuración adecuados.
Por defecto: mongodb://localhost:27017 Valores aceptados: una string URI de conexión de MongoDB
servidor.api.version
Type: string
Description: The Stable API version you want to use with your MongoDB server. For more information on the Stable API and versions of the server that support it, see the Stable API MongoDB server manual guide.
Default: "" Accepted Values: An empty string or a valid Stable API version.
servidor.api.deprecationErrors
Type: boolean
Description: When set to true, if the connector calls a command on your MongoDB instance that's deprecated in the declared Stable API version, it raises an exception.
You can set the API version with the server.api.version configuration option. For more information on the Stable API, see the MongoDB manual entry on the Stable API.
Default: false Accepted Values: true or false
servidor.api.strict
Type: boolean
Description: When set to true, if the connector calls a command on your MongoDB instance that's not covered in the declared Stable API version, it raises an exception.
You can set the API version with the server.api.version configuration option. For more information on the Stable API, see the MongoDB manual entry on the Stable API.
Default: false Accepted Values: true or false
Espacio de nombres de MongoDB
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.
Descripción: El nombre de clase completo de la clase que especifica en qué base de datos o colección se deben hundir los datos. El DefaultNamespaceMapper por defecto utiliza los valores especificados en las propiedades database y collection.
El conector incluye una clase alternativa para especificar la base de datos y la colección llamada FieldPathNamespaceMapper. Consulte Configuración de FieldPathNamespaceMapper para obtener más información.
Valores aceptados: un nombre de clase Java totalmente calificado de una clase que implemente la interfaz NamespaceMapper.
database
Requerido
Tipo: string
Descripción: El nombre de la base de datos de MongoDB en la que escribe el conector de receptor.
Valores aceptados: Un nombre de base de datos de MongoDB
Colección
Tipo: string
Descripción: El nombre de la colección de MongoDB a la que escribe el conector de receptor. Si el conector de receptor sigue varios temas, esta es la colección por defecto para cualquier guardados que no se especifique de otro modo.
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:
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 key o value a una base de datos
Una de las asignaciones de key o value a 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
Descripción: El nombre del campo del documento clave que especifica el nombre de la base de datos en la que se debe guardar.
namespace.mapper.key.colección.campo
Tipo: string
Descripción: El nombre del campo de documento clave que especifica el nombre de la colección en la que se va a guardar.
namespace.mapper.value.base de datos.campo
Tipo: string
Descripción: El nombre del campo del documento de valor que especifica el nombre de la base de datos en la que se va a guardar.
namespace.mapper.value.collection.field
Tipo: string
descripción: El nombre del campo del documento de valor que especifica el nombre de la colección en la que se va a guardar.
error inválido de mapeo de namespace
Tipo: booleano
Descripción: Si se debe lanzar una excepción cuando el documento no tiene el campo asignado o tiene un tipo BSON no válido.
Cuando se establece en true, el conector no procesa los documentos a los que les falta el campo asignado o que contienen un tipo BSON no válido. El conector puede detener o omitir el procesamiento según la configuración de manejo de errores relacionada.
Cuando se establece en false, si a un documento le falta el campo asignado o si tiene un tipo BSON no válido, el conector por defecto escribe en la configuración database y collection especificada.
Por defecto: false Valores aceptados: true o false
Connector Tema
Utiliza la siguiente configuración para especificar qué temas de Kafka debe monitorear el conector de sink de MongoDB Kafka en busca de datos.
Descripción: Una lista de temas de Kafka que el conector de receptor observa.
Puede definir la configuración topics o topics.regex, pero no ambas.
Valores aceptados: Una lista de temas válidos de Kafka separados por comas
regex
Requerido
Tipo: string
Descripción: Una expresión regular que coincide con los temas de Kafka que observa el conector de receptor.
Por ejemplo, la siguiente expresión regular coincide con nombres de temas como "activity.landing.clicks" y "activity.support.clicks". No coincide con los nombres de los temas "activity.landing.views" y "activity.clicks".
topics.regex=activity\\.\\w+\\.clicks$
Puede definir la configuración topics o topics.regex, pero no ambas.
Valores aceptados: un patrón válido de expresión regular utilizando java.util.regex.Pattern.
Procesamiento de mensajes del Connector
Utilice la configuración de esta página para configurar el comportamiento de procesamiento de mensajes del conector de sumidero de MongoDB Kafka, que incluye lo siguiente:
descripción: Número máximo de registros de sumidero para agrupar para su procesamiento.
Considera el grupo que contiene los siguientes registros:
[ 1, 2, 3, 4, 5 ]
Cuando se establece en 0, el conector realiza una única escritura masiva para todo el lote.
Cuando se establece en 1, el conector realiza una escritura masiva para cada registro del lote, para un total de cinco escrituras masivas como se muestra en el siguiente ejemplo:
[1], [2], [3], [4], [5]
Por defecto: 0 Valores aceptados: un número entero
bulk.guardar.ordered
Tipo: booleano
Descripción: Si el conector guarda un agrupar de registros como una operación de guardar masivo ordenado o no ordenado. Cuando se establece en true, el valor por defecto, el conector guarda un agrupar de registros como una operación de guardar masivo ordenado.
Descripción: Número de lotes de registros que el conector de receptor procesa para activar el tiempo de espera de limitación de velocidad. Un valor de 0 significa que no hay limitación de velocidad.
Por defecto: 0 Valores aceptados: Un número entero
rate.limiting.timeout
Tipo: int
Descripción: Cuánto tiempo (en milisegundos) esperar antes de que el conector de receptor reanude el procesamiento después de alcanzar el umbral de limitación de velocidad.
Por defecto: 0 Valores aceptados: un número entero
tasks.max
Tipo: int
Descripción: El número máximo de tareas que se pueden crear para este conector. El conector puede crear menos tareas de las máximas especificadas si no puede gestionar el nivel de paralelismo que especifique.
IMPORTANTE: Si especifica un valor superior a 1, el conector habilita el procesamiento paralelo de las tareas. Si su tema tiene varios registros de partición, lo que permite al conector leer del tema en paralelo, las tareas pueden procesar los mensajes fuera de orden.
Por defecto: 1 Valores aceptados: Un número entero
Manejo de errores del conector
Utiliza las siguientes configuraciones para especificar cómo el conector MongoDB Kafka sink maneja los errores y para configurar la fila de letra muerta.
Description: Whether to continue processing messages if the connector encounters an error. Allows the connector to override the errors.tolerance Kafka cluster setting.
When set to none, the connector reports any error and blocks further processing of the rest of the messages.
When set to all, the connector ignores any problematic messages.
When set to data, the connector tolerates only data errors and fails on all other errors.
To learn more about error handling strategies, see the Handle Errors page.
This property overrides the errors.tolerance property of the Connect Framework.
Default: Inherits the value from the errors.tolerance setting. Accepted Values: "none" or "all"
mongo.errors.log.enable
Type: boolean
Description: Whether the connector should write details of errors including failed operations to the log file. The connector classifies errors as "tolerated" or "not tolerated" using the errors.tolerance or mongo.errors.tolerance settings.
When set to true, the connector logs both "tolerated" and "not tolerated" errors. When set to false, the connector logs "not tolerated" errors.
This property overrides the errors.log.enable property of the Connect Framework.
Default:false Accepted Values: true or false
Incluir mensajes
Tipo: booleano
Descripción: Si el conector debe incluir el mensaje no válido al registrar un error. Un mensaje no válido incluye datos como claves de registro, valores y encabezados.
Por defecto:false Valores aceptados: true o false
errors.deadletterqueue.tema.name
Tipo: string
Descripción: Nombre del tema que se utilizará como fila de letra muerta. Si está en blanco, el conector no enviará ningún mensaje no válido a la fila de letra muerta.
Descripción: El número de nodos en los que se replica el tema de la fila de letra muerta. Si está ejecutando un clúster de Kafka de un solo nodo, debe establecerlo en 1.
Por defecto:3 Valores aceptados: un número válido de nodos
Post-processors
Utiliza la siguiente configuración para especificar cómo el conector de sink de MongoDB Kafka debe transformar los datos de Kafka antes de insertarlos en MongoDB.
Valores aceptados: una lista separada por comas de nombres de clases Java completamente calificados
campo.renamer.mapping
Tipo: string
Descripción: Una lista de asignaciones de nombres de campo para campos clave y de valor. Defina las asignaciones en un arreglo JSON en línea en el siguiente formato:
Por defecto: [] Valores aceptados: un arreglo JSON válido
field.renamer.regexp
Tipo: string
Descripción: Una lista de asignaciones de nombres de campo para campos clave y de valor mediante expresiones regulares. Defina las asignaciones en un arreglo JSON en línea en el siguiente formato:
Valores aceptados: un nombre de clase Java completamente calificado
ID Strategy
Utilice la siguiente configuración para especificar cómo el conector MongoDB Kafka sink debe determinar el valor de _id para cada documento que escriba en MongoDB.
Valores aceptados: Una string vacía o un nombre de clase Java totalmente calificado
document.id.strategy.overwrite.existing
Tipo: booleano
Descripción: Si el conector debe sobrescribir los valores existentes en el campo _id cuando aplica la estrategia definida por la propiedad document.id.strategy.
Por defecto: false Valores aceptados: true o false
document.id.estrategia.uuid.formato
Tipo: cadena
Descripción: Indica si el conector debe mostrar el UUID del _id campo en formato de cadena o en formato BsonBinary.
string Valor predeterminado: Valores aceptados: string o binary
Borrar en valores nulos
Tipo: booleano
Descripción: Si el conector debe borrar documentos cuando el valor clave coincide con un documento en MongoDB y el campo de valor es nulo.
Esta configuración se aplica cuando se especifica una estrategia de generación de ID que opera en el documento clave, como FullKeyStrategy, PartialKeyStrategy y ProvidedInKeyStrategy.
Por defecto: false Valores aceptados: true o false
Guardar Estrategia del modelo
Puedes establecer propiedades de configuración para especificar cómo el conector sink de Kafka de MongoDB escribe datos en MongoDB. Las siguientes secciones describen las propiedades de configuración que se pueden configurar para personalizar este comportamiento.
Modelo de guardar
Establece la propiedad de configuración writemodel.strategy para especificar cómo el conector sink escribe datos cuando recibe un registro sink.
Puede establecer el valor de writemodel.strategy en cualquiera de los nombres de clase totalmente calificados de las estrategias del modelo de guardar descritas en la sección Estrategias de esta página. Puede especificar una estrategia configurando lo siguiente:
writemodel.strategy=<a write model strategy>
Eliminar modelo guardar
Establece la propiedad de configuración delete.writemodel.strategy para especificar cómo el conector del destino escribe datos al recibir un evento tombstone. Un evento tombstone es un registro que contiene una clave pero sin valor, lo que indica un registro borrado.
Puede establecer el valor de delete.writemodel.strategy en cualquiera de los nombres de clase totalmente calificados de las estrategias del modelo de guardar descritas en la sección Estrategias de esta página. Puede especificar una estrategia configurando lo siguiente:
delete.writemodel.strategy=<a write model strategy>
descripción: Esta estrategia utiliza el ReplaceOneDefaultStrategy por defecto y el InsertOneDefaultStrategy si establece la opción timeseries.timefield.
Este es el valor por defecto para la propiedad de configuración writemodel.strategy.
InsertOneDefaultStrategy
descripción: Inserte cada registro de receptor en MongoDB como un documento. Para especificar esta estrategia, establezca la propiedad de configuración en el siguiente nombre de clase:
descripción: Reemplaza como máximo un documento en MongoDB que coincida con un registro de receptor por el campo _id. Si no hay documentos que coincidan, el conector inserta el registro del receptor como un nuevo documento. Para especificar esta estrategia, establezca la propiedad de configuración en el siguiente nombre de clase:
descripción: Reemplaza como máximo un documento que coincide con un registro de receptor mediante una clave comercial especificada. Si no hay documentos que coincidan, el conector inserta el registro del receptor como un nuevo documento. Para especificar esta estrategia, establezca la propiedad de configuración en el siguiente nombre de clase:
descripción: Borra como máximo un documento que coincida con la estructura de clave de su conector de receptor solo por el campo _id cuando el documento contenga una estructura de valor nulo.
Este es el valor por defecto de la propiedad de configuración delete.writemodel.strategy.
Esta estrategia se establece como el valor por defecto de la propiedad writemodel.strategy cuando se establece delete.on.null.values=true. Para especificar esta estrategia, establezca la propiedad de configuración en el siguiente nombre de clase:
descripción: Elimina como máximo un documento de MongoDB que coincida con un registro de sumidero mediante una clave empresarial. Para especificar esta estrategia, establezca la propiedad de configuración en el siguiente nombre de clase:
descripción: Actualiza como máximo un documento en MongoDB que coincida con un registro de receptor por el campo _id. Si no hay documentos que coincidan, el conector inserta el registro del receptor como un nuevo documento. Para especificar esta estrategia, establezca la propiedad de configuración en el siguiente nombre de clase:
descripción: Agregue los campos _insertedTS (marca de tiempo insertada) y _modifiedTS (marca de tiempo modificada) en los documentos. Para especificar esta estrategia, establezca la propiedad de configuración en el siguiente nombre de clase:
descripción: Agregue los campos _insertedTS (marca de tiempo insertada) y _modifiedTS (marca de tiempo modificada) en los documentos que coincidan con una llave comercial. Para especificar esta estrategia, establezca la propiedad de configuración en el siguiente nombre de clase:
Utilice la siguiente configuración del conector de destino de MongoDB Kafka para reemplazar la configuración global o por defecto de propiedades para temas específicos.
Para ver solo las opciones relacionadas con la anulación de la configuración del tema, consulta la página de Propiedades de anulación de temas.
Nombre
Descripción
tema.override.<topicName>.<propertyName>
Tipo: string
Descripción: Especifica un tema y un nombre de propiedad para anular la configuración de propiedad global o por defecto correspondiente.
Por ejemplo, la topic.override.foo.collection=bar configuración indica al conector de receptor que almacene datos del foo tema en la bar colección.
Puedes especificar cualquier configuración válida en el <propertyName> segmento por tema, excepto connection.uritopicsy.
Por defecto: "" Valores aceptados: Valores aceptados específicos de la propiedad anulada
Captura de cambio de datos
Utiliza las siguientes configuraciones para especificar la clase que el conector de sumidero de MongoDB Kafka utiliza para procesar eventos de captación de datos de cambios (CDC).
Consulta la guía sobre Controladores de captura de cambios de datos para ejemplos utilizando los controladores de funcionalidad incorporada ChangeStreamHandler y los controladores para los productores de eventos Debezium y Qlik Replicate.
Descripción: El nombre de la clase del controlador CDC que se utilizará para convertir los cambios en flujos de eventos. Consulte Controladores CDC disponibles para obtener una lista de controladores CDC.
Por defecto: "" Valores aceptados: Una string vacía o un nombre de clase Java totalmente calificado
Time Series
Utiliza la siguiente configuración para especificar cómo el conector MongoDB Kafka sink debe enviar datos a una colección de series de tiempo de MongoDB.
Para ver solo las opciones relacionadas con colecciones de series de tiempo, consulta la página de Propiedades de Kafka Time Series.
Nombre
Descripción
timeseries.timefield
Tipo: string
descripción: El nombre del campo de nivel superior en los datos de origen que contiene la información de tiempo que desea asociar con el nuevo documento en la colección de series de tiempo.
por defecto: "" Valores aceptados: Una string vacía o el nombre de un campo que contiene un valor BSON DateTime
timeseries.timefield.auto.convert.date.format
Tipo: cadena
Descripción: El patrón de formato de fecha que el conector debe usar para convertir los datos de origen contenidos en el campo especificado por la timeseries.timefield configuración.
de hora. Si el valor de fecha de los datos de origen solo contiene información de fecha, el conector establece la información de hora al inicio del día especificado. Si el valor de fecha no contiene el desplazamiento de zona horaria, el conector establece el desplazamiento en UTC.
Valores aceptados: Un formato válido de DateTimeFormatter
timeseries.timefield.auto.convert
Tipo: booleano
Descripción: Si se deben convertir los datos del campo al formato BSON Date.
Cuando se establece en true, el conector utiliza los milisegundos después de Unix epoch y descarta las partes fraccionarias si el valor es un número. Si el valor es un string, el conector utiliza la configuración siguiente para analizar la fecha:
timeseries.timefield.auto.convert.date.format
Si el conector no puede convertir el valor, envía el valor original a la colección de series de tiempo.
Por defecto: false Valores aceptados: true o false
Etiqueta de lenguaje de conversión automática del campo de hora en serie temporal de localización
Tipo: cadena
Descripción: Qué DateTimeFormatter etiqueta de idioma de configuración regional usar con el patrón de formato de fecha (p. "en-US" ej.,).
Para obtener más información sobre configuraciones regionales, consulte la documentación de Java SE sobre Locale.
Valor predeterminado: ROOT Valores aceptados: Un Locale formato de etiqueta de idioma válido
timeseries.metafield
Tipo: string
Descripción: qué campo de nivel superior leer de los datos de origen para describir un grupo de documentos de serie de tiempo relacionados.
IMPORTANTE: este campo no debe ser el campo _id ni el campo que especificaste en la configuración timeseries.timefield.
Por defecto: "" Valores aceptados: una string vacía o el nombre de un campo que contiene cualquier tipo BSON, excepto BsonArray.
Las series temporales expiran después de segundos
Tipo: int
Descripción: El número de segundos que MongoDB debe esperar antes de eliminar automáticamente los datos de la colección de series temporales. El conector desactiva la caducidad programada cuando el valor de configuración es menor 1 que.