Core - Mejoras, Cambios y Soluciones

Plataforma IPF: Journal processor documentación añadida a Flo Starter Proyectos

Conector: Propiedad de configuración añadida para el tiempo de espera de la llamada a la CorrelationService in SendConnector. Valor predeterminado proporcionado en ipf.connector.default-send-connector.correlation-stage-timeout de 5s.

MongoDB: Se añadió la capacidad de establecer el quórum de confirmación. Puede establecerse globalmente para la creación de todos los índices con ipf.mongodb.commit-quorum. Consulte la documentación de cada componente individual para saber cómo anular por componente.

IPF Processing Data: Los exportadores pueden generar datos para diferentes Kafka temas, configurables por data type.

Flo-lang y Akka-persistence-mongo-db: Se añadió una funcionalidad de purga configurable para las colecciones de diario y de instantáneas. La funcionalidad predeterminada es no purgar documentos de ninguna de las colecciones. La implementación utiliza índices ttl de Mongo y Cosmos que deberán ser creados manualmente. Las guías de configuración se encuentran en la documentación:

Persistent Scheduler se añadió soporte para zonas horarias a persistent scheduler

Poller de Archivos IPF-Cambio drástico- Para soportar múltiples entidades de procesamiento, el IPF File Poller ahora puede sondear desde múltiples ubicaciones. Esto significa que la siguiente configuración ha cambiado de un solo elemento a una lista de elementos:`ipf.file-poller`→`ipf.file-poller.pollers`

Dynamic Settings Workflow- Se eliminó la llamada redundante al convertidor de archivos durante la ingestión de archivos del procesador de archivos. Este problema estaba afectando CSM Reachability Ingesta de Datos: procesamiento de archivos FileEntrySkippedEvent y PartyEntityDirectorySubTypeMappingSkippedEvent events se levantaron dos veces y se registraron errores dos veces.

Dynamic Settings Workflow- Añadido nuevo event y enriquecido existente events. Mejorará la supervisión, para los ya existentes FileEntrySkippedEvent con tipo y fileName,ProcessingCompleteEvent con tipo, resultado, nombre_archivo y nombre_proceso y ProcessingFailedEvent con processName y fileName. También se añadió nuevo FileEntryProcessedEvent con tipo de métricas y fileName(más información al respecto en Csm Reachability y la ingestión de datos de la industria)

Reemplazando Caffeine sincronizar cache implementación con async cache implementación para corregir múltiples llamadas a la devolución de llamada en getOrDefault método en ipf-cache-caffeine módulo.

Actualizado EventProcessorStream para usar mapAsyncPartitioned en lugar del anterior mapAsync operador. Ahora, incluso cuando el paralelismo esté habilitado, no estaremos procesando relacionados.events en paralelo dentro de un único flujo, así journal processor s debe ser paralelizado de manera segura.

Ipf-file-manager - S3File Reader corregido para poder descargar archivos más grandes.

Conector:`IngestedFile` as ReceivedMessage’el contexto de 's ha sido reemplazado por'`IngestedFileContext

IPF Processing Data: Actualizado MdsWrapper restricción de tipo genérico de la clase. El parámetro genérico T debe implementar ahora java.io. Serializable

Transacción IPF Cache- cambió los nombres de los índices que se están creando en transactionCacheEntry mongodb colección:

Conector- Consumo de memoria en LocalDirectoryConnectorTransport componente

Archivador IPF- Se solucionó un problema donde ocurrían errores al entregar paquetes de archivo a Kafka no se propagaron correctamente, lo que resultó en la falta de paquetes de archivo.