Novedades

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 ha corregido un error donde los datos se copian de nuevo cuando una tarea se reinicia. Para obtener más información sobre esta corrección, consulta el KAFKA-428 issue 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.