Novedades

Se añadió la compatibilidad con el cifrado a nivel de campo del lado del cliente (CSFLE) para el conector de sink. Esto incluye los siguientes nuevos Opciones de configuración de la conexión de MongoDB:

• csfle.enabled

• csfle.key.vault.namespace

• csfle.local.master.key

• csfle.schema.map

• csfle.bypass.query.analysis

Se añadió soporte para la desencriptación sin estado de campos para el conector de sumidero. Esto incluye las siguientes opciones de configuración de post-procesador:

• field.value.transformer

• field.value.transformer.fields

Dependencia de Apache Kafka actualizada para abordar vulnerabilidades de seguridad.

Se actualizó el comportamiento del conector para que apunte explícitamente a TLS v1.3 como el protocolo seguro preferido y, si v1.3 no está disponible, recurrir a TLS v1.2. El método getSecureSslContext() ahora devuelve un SSLContext configurado con TLS v1.3 o v1.2, y lanza NoSuchAlgorithmException si ninguno está disponible.

Se cambió el mensaje de registro del nivel WARN al ERROR cuando el conector no logra reanudar un flujo de cambios. Estos errores ahora se reflejan en las métricas de fallos.

Se actualizó la dependencia de Apache Kafka para abordar vulnerabilidades de seguridad.

Se agregó el DeleteOneTombstoneBusinessKeyStrategy para cambiar la configuración del conector del sumidero de flujo de cambios.

Se agregó la configuración del conector de fuente de flujo de cambios change.stream.show.expanded.events.

Se solucionó un problema introducido en la versión 3.9 de Apache Kafka relacionado con la clase Kafka SystemTime.

Se añadió soporte para remover todos los campos con valor nulo en la salida con el posprocesador predefinido NullFieldValueRemover. Para obtener más información, consulte Postprocesadores preconstruidos.

Se corrigió un error que causaba que los datos se duplicaran al reiniciar una tarea. Para obtener más información sobre esta solución, consulta la KAFKA-428 Incidencia de JIRA.

Se añadió una interfaz personalizada de proveedor de autenticación para los conectores Source y Sink. Esta funcionalidad te permite escribir y usar una clase de implementación personalizada en tu conector. Para obtener más información, consulta la guía Proveedor de autenticación personalizado.

Se solucionó un problema que si tenía lugar al validar la configuración de los conectores de origen y destino si la configuración contenía secretos y usaba el framework Provider. Para obtener más información sobre esta solución, consulta el problema JIRA KAFKA-414.

Se añadió el soporte para un valor de configuración data en el ajuste de configuración mongo.errors.tolerance. Con mongo.errors.tolerance=data, el conector sink tolera únicamente errores de datos y falla ante cualquier otro tipo de error.