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.
Descripción: La cadena URI de conexión de MongoDB para conectarse a su instancia o clúster de MongoDB. Para obtener más información, consulte la guía Conectarse a MongoDB.
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.
mongodb://localhost:27017 Valor predeterminado: Valores aceptados: Una cadena URI de conexión de MongoDB
servidor.api.version
Tipo: string
Descripción: La versión Stable API que deseas usar con tu servidor MongoDB. Para obtener más información sobre la Stable API y las versiones del servidor que la admiten, consulta la Stable API en la guía del manual de servidor de MongoDB.
Por defecto: "" Valores aceptados: Una string vacía o una versión válida de la Stable API.
servidor.api.deprecationErrors
Tipo: booleano
Descripción: Cuando true se establece en, si el conector llama a un comando en su instancia de MongoDB que está obsoleto en la versión declarada de la API estable, se generará una excepción.
false Valor predeterminado: Valores aceptados: true o false
servidor.api.strict
Tipo: booleano
Descripción: Cuando true se establece en, si el conector llama a un comando en su instancia de MongoDB que no está cubierto por la versión de API estable declarada, se generará una excepción.
Puede establecer la versión de la API con la server.api.version opción de configuración. Para obtener más información sobre la API estable, consulte la entrada del manual de MongoDB sobre la API estable.
false Valor predeterminado: Valores aceptados: true o 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 almacenarán los datos. El DefaultNamespaceMapper valor predeterminado utiliza los valores especificados en las database propiedades collection y.
Valores aceptados: un nombre de clase Java totalmente calificado de una clase que implemente la interfaz NamespaceMapper.
database
Requerido
Tipo: cadena
Descripción: El nombre de la base de datos MongoDB en la que escribe el conector de destino.
Valores aceptados: Un nombre de base de datos MongoDB
Colección
Tipo: cadena
Descripción: El nombre de la colección de MongoDB en la que escribe el conector de destino. Si su conector de destino sigue varios temas, esta es la colección predeterminada para cualquier escritura que no se especifique de otra manera.
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: cadena
Descripción: El nombre del campo clave del documento que especifica el nombre de la base de datos en la que se escribirá.
namespace.mapper.key.colección.campo
Tipo: cadena
Descripción: El nombre del campo clave del documento que especifica el nombre de la colección en la que se escribirá.
namespace.mapper.value.base de datos.campo
Tipo: cadena
Descripción: El nombre del campo del documento de valor que especifica el nombre de la base de datos en la que se escribirá.
namespace.mapper.value.collection.field
Tipo: cadena
Descripción: El nombre del campo del documento de valor que especifica el nombre de la colección en la que se escribirá.
error inválido de mapeo de namespace
Tipo: booleano
Descripción: Indica si se debe generar una excepción cuando al documento le falta el campo asignado o si tiene un tipo BSON no válido.
Si se establece true en, el conector no procesa los documentos que no tienen el campo asignado o que contienen un tipo BSON no válido. El conector puede detener u omitir el procesamiento según la configuración de manejo de errores correspondiente.
Si false se establece en, si a un documento le falta el campo asignado o si tiene un tipo BSON no válido, el conector escribe databasecollection
pordefecto en las configuraciones y especificadas.false Valor predeterminado: 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 destino monitoriza.
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: cadena
Descripción: Una expresión regular que coincide con los temas de Kafka que monitorea el conector de destino.
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 destino que se agruparán para su procesamiento.
Considere el lote que contiene los siguientes registros:
[ 1, 2, 3, 4, 5 ]
Cuando 0 se establece en, el conector realiza una única escritura masiva para todo el lote.
Cuando 1 se establece en, 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]
Valor predeterminado: 0 Valores aceptados: Un número entero
bulk.guardar.ordered
Tipo: booleano
Descripción: Indica si el conector escribe un lote de registros como una operación de escritura masiva ordenada o no ordenada. Cuando se establece true en, el valor predeterminado, el conector escribe un lote de registros como una operación de escritura masiva ordenada.
Para obtener más información sobre las operaciones de escritura masiva, consulte Operaciones de escritura masiva.
Valor predeterminado: true Valores aceptados: true o false
límite de: cada n
Tipo: int
Descripción: Número de lotes de registros que el conector de destino procesa para activar el tiempo de espera de limitación de velocidad. Un valor de 0 significa que no hay limitación de velocidad.
Valor predeterminado: 0 Valores aceptados: Un número entero
rate.limiting.timeout
Tipo: int
Descripción: Tiempo (en milisegundos) que debe transcurrir antes de que el conector de destino reanude el procesamiento tras alcanzar el umbral de limitación de velocidad.
Valor predeterminado: 0 Valores aceptados: Un número entero
tasks.max
Tipo: int
Descripción: El número máximo de tareas que se crearán para este conector. El conector puede
crear 1 menos tareas de
las1 especificadas si no puede manejar el nivel de paralelismo que usted indique. IMPORTANTE: Si especifica un valor mayor que, 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. Valor predeterminado: 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.
Descripción: Indica si se deben continuar procesando los mensajes si el conector encuentra un error. Permite que el conector anule la errors.tolerance configuración del clúster de Kafka.
Cuando se establece none en, el conector informa de cualquier error y bloquea el procesamiento posterior del resto de los mensajes.
Cuando se establece all en, el conector ignora cualquier mensaje problemático.
Cuando se establece data en, el conector tolera solo errores de datos y falla ante cualquier otro error.
Para obtener más información sobre las estrategias de manejo de errores, consulte la página Manejo
de errores. Esta propiedad anula la propiedad errors.tolerance del Connect Framework.
Predeterminado: Hereda el valor de la errors.tolerance configuración. Valores aceptados: "none" o "all"
mongo.errors.log.enable
Tipo: booleano
Descripción: Indica si el conector debe escribir detalles de errores, incluidas las operaciones fallidas, en el archivo de registro. El conector clasifica los errores como "tolerados" o "no tolerados" mediante las errors.tolerancemongo.errors.tolerance configuraciones o.
Cuando true se establece en, el conector registra tanto los errores "tolerados" como los "no tolerados". Cuando false se establece en, el conector registra los errores "no tolerados".
Esta propiedad anula la propiedad errors.log.enable del Connect Framework.
false Valor predeterminado: Valores aceptados: true o false
Incluir mensajes
Tipo: booleano
Descripción: Indica si el conector debe incluir el mensaje de error al registrar un error. Un mensaje de error incluye datos como claves, valores y encabezados de registro.
false Valor predeterminado: Valores aceptados: true o false
errors.deadletterqueue.tema.name
Tipo: cadena
Descripción: Nombre del tema que se utilizará como cola de mensajes no entregados. Si está en blanco, el conector no enviará ningún mensaje no válido a la cola de mensajes no entregados.
Para obtener más información sobre las excepciones que el conector define e informa a través de los encabezados de contexto, consulte Excepciones de escritura masiva.
false Valor predeterminado: Valores aceptados: true o false
errors.deadletterqueue.tema.replicación.factor
Tipo: entero
Descripción: Número de nodos en los que se replicará el tema de la cola de mensajes fallidos. Si está ejecutando un clúster Kafka de un solo nodo, debe establecer este valor 1 en.
3 Valor predeterminado: 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: cadena
Descripción: Una lista de asignaciones de nombres de campo para campos clave y valor. Defina las asignaciones en una matriz JSON en línea con el siguiente formato:
Valor predeterminado: [] Valores aceptados: Un array JSON válido
field.renamer.regexp
Tipo: cadena
Descripción: Una lista de asignaciones de nombres de campo para campos clave y valor mediante expresiones regulares. Defina las asignaciones en una matriz JSON en línea con 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: Indica si el conector debe sobrescribir los valores existentes en el _id campo al aplicar la estrategia definida por la document.id.strategy propiedad.
false Valor predeterminado: 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: Indica si el conector debe eliminar documentos cuando el valor de la 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 sobre el documento clave,FullKeyStrategy como, PartialKeyStrategyProvidedInKeyStrategyy.
false Valor predeterminado: 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 ReplaceOneDefaultStrategyInsertOneDefaultStrategy el timeseries.timefield valor por defecto, y el valor si se selecciona la opción.
Este es el valor predeterminado para la writemodel.strategy propiedad de configuración.
InsertOneDefaultStrategy
descripción: Inserta cada registro de destino en MongoDB como un documento. Para especificar esta estrategia, establece la propiedad de configuración con el siguiente nombre de clase:
descripción: Reemplaza como máximo un documento en MongoDB que coincida con un registro de destino por el _id campo. Si no hay documentos coincidentes, el conector inserta el registro de destino como un nuevo documento. Para especificar esta estrategia, establezca la propiedad de configuración con el siguiente nombre de clase:
descripción: Reemplaza como máximo un documento que coincida con un registro de destino por una clave de negocio específica. Si no hay documentos coincidentes, el conector inserta el registro de destino como un nuevo documento. Para especificar esta estrategia, establezca la propiedad de configuración con el siguiente nombre de clase:
descripción: Elimina como máximo un documento que coincida con la estructura de clave de su conector de destino mediante el _id campo solo cuando el documento contiene una estructura de valor nulo.
Este es el valor predeterminado para la delete.writemodel.strategy propiedad de configuración.
Esta estrategia se establece como el valor predeterminado de la writemodel.strategy propiedad cuando se delete.on.null.values=true establece. Para especificar esta estrategia, establezca la propiedad de configuración con el siguiente nombre de clase:
descripción: Elimina como máximo un documento de MongoDB que coincida con un registro de destino mediante una clave de negocio. Esta estrategia requiere un valueDoc para la generación de claves. Para aprovechar el PartialKeyStrategy para la generación de claves, utilice DeleteOneTombstoneBusinessKeyStrategy el.
Para especificar esta estrategia, establezca la propiedad de configuración con el siguiente nombre de clase:
descripción: Elimina como máximo un documento de MongoDB que coincida con un registro de destino mediante una clave de negocio. Esta estrategia utiliza PartialKeyStrategy el valor para crear la clave utilizada para la eliminación.
Para especificar esta estrategia, establezca la propiedad de configuración con el siguiente nombre de clase:
descripción: Actualiza como máximo un documento en MongoDB que coincida con un registro de destino mediante el _id campo. Si no hay coincidencias, el conector inserta el registro de destino como un nuevo documento. Para especificar esta estrategia, establezca la propiedad de configuración con el siguiente nombre de clase:
descripción: Agregue _insertedTS los campos (marca de tiempo insertada) y _modifiedTS (marca de tiempo modificada) a los documentos. Para especificar esta estrategia, establezca la propiedad de configuración con el siguiente nombre de clase:
descripción: Agregue _insertedTS los campos (marca de tiempo insertada) y _modifiedTS (marca de tiempo modificada) a los documentos que coincidan con una clave de negocio. Para especificar esta estrategia, establezca la propiedad de configuración con 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: cadena
Descripción: Especifique un tema y un nombre de propiedad para anular la configuración de propiedad global o predeterminada correspondiente.
Por ejemplo, la topic.override.foo.collection=bar configuración indica al foo conector de bar destino que almacene los datos del tema en la colección.
Puede especificar cualquier configuración válida en el segmento para cada <propertyName> tema, excepto connection.uritopicsy.
Predeterminado: "" 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 los controladores CDC.
"" Valor predeterminado: Valores aceptados: Una cadena vacía o un nombre de clase Java completo
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: cadena
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 temporales.
"" Valor predeterminado: Valores aceptados: Una cadena vacía o el nombre de un campo que contiene un DateTime valor BSON.
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: Indica si se deben convertir los datos del campo al Date formato BSON.
Cuando se establece true en, el conector utiliza los milisegundos posteriores a la época y descarta las partes fraccionarias si el valor es un número. Si el valor es una cadena, el conector utiliza la configuración que se muestra a continuación para analizar la fecha:
timeseries.timefield.auto.convert.date.format
Si el conector no logra convertir el valor, envía el valor original a la colección de series temporales.
false Valor predeterminado:. 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 (por"en-US" ejemplo,).
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: cadena
Descripción: Campo de nivel superior que se leerá de los datos de origen para describir un grupo de documentos de series temporales relacionados.
IMPORTANTE: Este campo no debe ser el _id campo ni el campo especificado en la timeseries.timefield configuración.
"" Valor predeterminado: Valores aceptados: Una cadena vacía o el nombre de un campo que contenga cualquier tipo BSON BsonArray excepto.
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.