Propiedades de procesamiento de mensajes del Connector

Overview

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:

Tamaño del lote de mensajes
Límites de frecuencia
Número de tareas paralelas

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

max.batch.size

Tipo: int

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.

Para obtener más información sobre las operaciones de escritura masiva, consulte Operaciones de escritura masiva.

Por defecto: 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 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