Core - Mejoras, Cambios y Soluciones

Plataforma IPF: Documentación del procesador de revistas 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 tipo de dato.

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 de zona horaria 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: Se generaron eventos de procesamiento de archivos FileEntrySkippedEvent y PartyEntityDirectorySubTypeMappingSkippedEvent dos veces y se registraron errores dos veces.

Dynamic Settings Workflow- Se ha añadido un nuevo evento y se han enriquecido los eventos existentes. Esto mejorará la supervisión de 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 el tipo de métricas y fileName(más información en Csm Reachability y la ingestión de datos de la industria)

Reemplazando Caffeine sincronizar la implementación de caché síncrona con la implementación de caché asíncrona para corregir múltiples llamadas al callback en getOrDefault método en ipf-cache-caffeine módulo.

Actualizado EventProcessorStream usar mapAsyncPartitioned en lugar del anterior mapAsync operador. Ahora, incluso cuando se habilita el paralelismo de procesamiento, no procesaremos eventos relacionados en paralelo dentro de un solo flujo, por lo tanto, los procesadores de registros deben ser paralelizados 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- cambiaron los nombres de los índices que se están creando en la colección transactionCacheEntry de mongodb:

Conector- Consumo de memoria en LocalDirectoryConnectorTransport componente

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