Ingreso Processing Data

Resumen

Los módulos ipf-processing-data-ingress deben ser utilizados en aplicaciones que necesiten consumir ipf processing data, p. ej. ODS.

Transporte

El ipf-processing-data egress envía IPF Processing Data sobres sobre kafka, o http, y hay componentes de ingress correspondientes para consumir estos datos.

Kafka

<dependency>
    <groupId>com.iconsolutions.ipf.core.processingdata</groupId>
    <artifactId>ipf-processing-data-ingress-kafka</artifactId>
</dependency>
Clave de configuración Valor predeterminado Descripción

ipf.processing-data.ingress.transport

kafka

Habilite o deshabilite el kafka ingreso. Cualquier cosa que no sea kafka lo desactivará.

ipf.processing-data.ingress.kafka.consumer.topic

IPF_PROCESSING_DATA

El tema del cual consumir IPF Processing Data sobres.

ipf.processing-data.ingress.kafka.consumer.topics

Los temas de los cuales consumir IPF Processing Data sobres, p. ej.[ TOPIC_A, TOPIC_B ]

El kafka ingress utiliza un kafka receive connector, configuración adicional bajo la clave ipf.processing-data.ingress.kafka.consumer.* se puede encontrar en el Configuración del conector or Kafka Introducción Rápida.

Métricas

Las siguientes métricas serán reportadas por el kafka ingreso:

  • ipf_processing_data_ingest_latency, que registra la duración entre el momento Process objects(domain event,system event,message log..), MDS objetos,PDS objetos, y Custom Los objetos han sido creados y el tiempo en que han sido procesados con éxito por el consumidor Ingress; las duraciones serán sensibles a la desviación temporal entre los servidores, por lo que deben ser tratadas únicamente como estimaciones.

  • ipf_processing_data_ingress_batch_receive_size, que registra el tamaño de cada DataEnvelope lote recibido por su BatchedIpfProcessingDataHandler spring bean. Consulte el guide to consuming processing data para más información sobre el manejo de lotes.

HTTP

<dependency>
    <groupId>com.iconsolutions.ipf.core.processingdata</groupId>
    <artifactId>ipf-processing-data-ingress-http</artifactId>
</dependency>

Responde a http POST requests containing an IPF Processing Data sobre con http estado ACCEPTED (202).

El punto final es un controlador de spring webflux y, por lo tanto, deberá residir dentro de una aplicación de spring webflux. La configuración específica para spring-framework y spring-web se puede encontrar en spring.io.